fix: isort linter issue!

dags/analyzer_helper/telegram/extract_raw_members.py

@@ -2,8 +2,8 @@
     DateTimeFormatConverter,
 )
 from github.neo4j_storage.neo4j_connection import Neo4jConnection
-from tc_hivemind_backend.db.mongo import MongoSingleton
 from pymongo import DESCENDING
+from tc_hivemind_backend.db.mongo import MongoSingleton
 
 
 class ExtractRawMembers:

dags/hivemind_etl_helpers/github_etl.py

@@ -2,7 +2,6 @@
 from datetime import datetime
 
 from dotenv import load_dotenv
-from tc_hivemind_backend.ingest_qdrant import CustomIngestionPipeline
 from hivemind_etl_helpers.src.db.github.extract import (
     GithubExtraction,
     fetch_issues,
@@ -13,6 +12,7 @@
 )
 from hivemind_etl_helpers.src.db.github.transform import GitHubTransformation
 from llama_index.core import Document
+from tc_hivemind_backend.ingest_qdrant import CustomIngestionPipeline
 
 
 def process_github_vectorstore(

dags/hivemind_etl_helpers/mediawiki_etl.py

@@ -1,7 +1,7 @@
 import logging
 
-from tc_hivemind_backend.ingest_qdrant import CustomIngestionPipeline
 from hivemind_etl_helpers.src.db.mediawiki.extractor import MediaWikiExtractor
+from tc_hivemind_backend.ingest_qdrant import CustomIngestionPipeline
 
 
 def process_mediawiki_etl(

dags/hivemind_etl_helpers/notion_etl.py

@@ -1,7 +1,7 @@
 import logging
 
-from tc_hivemind_backend.ingest_qdrant import CustomIngestionPipeline
 from hivemind_etl_helpers.src.db.notion.extractor import NotionExtractor
+from tc_hivemind_backend.ingest_qdrant import CustomIngestionPipeline
 
 
 class NotionProcessor:

dags/hivemind_etl_helpers/tests/integration/test_discord_prepare_summary.py

@@ -3,9 +3,9 @@
 
 from bson import ObjectId
 from hivemind_etl_helpers.src.db.discord.discord_summary import DiscordSummary
-from tc_hivemind_backend.db.mongo import MongoSingleton
 from llama_index.core import Document, MockEmbedding, Settings
 from llama_index.core.llms import MockLLM
+from tc_hivemind_backend.db.mongo import MongoSingleton
 
 
 class TestDiscordGroupedDataPreparation(TestCase):

dags/hivemind_etl_helpers/tests/integration/test_discord_prepare_thread_summaries.py

@@ -4,9 +4,9 @@
 from hivemind_etl_helpers.src.db.discord.summary.prepare_summaries import (
     PrepareSummaries,
 )
-from tc_hivemind_backend.db.mongo import MongoSingleton
 from llama_index.core import MockEmbedding, Settings
 from llama_index.core.llms import MockLLM
+from tc_hivemind_backend.db.mongo import MongoSingleton
 
 
 class TestPrepareSummaries(unittest.TestCase):

dags/hivemind_etl_helpers/tests/integration/test_ingestion_pipeline_etl.py

@@ -1,9 +1,9 @@
 import unittest
 from unittest.mock import Mock
 
-from tc_hivemind_backend.ingest_qdrant import CustomIngestionPipeline
 from llama_index.core.ingestion import IngestionPipeline
 from llama_index.core.schema import Document
+from tc_hivemind_backend.ingest_qdrant import CustomIngestionPipeline
 
 
 class TestIngestionPipeline(unittest.TestCase):

dags/hivemind_etl_helpers/tests/integration/test_pg_vector_access_with_discord.py

@@ -6,9 +6,9 @@
 from hivemind_etl_helpers.src.db.discord.discord_raw_message_to_document import (
     discord_raw_to_documents,
 )
-from tc_hivemind_backend.db.mongo import MongoSingleton
 from llama_index.core.indices.vector_store import VectorStoreIndex
 from tc_hivemind_backend.db.credentials import load_postgres_credentials
+from tc_hivemind_backend.db.mongo import MongoSingleton
 from tc_hivemind_backend.db.pg_db_utils import setup_db
 from tc_hivemind_backend.pg_vector_access import PGVectorAccess
 

dags/hivemind_google_drive_etl.py

@@ -5,9 +5,9 @@
 
 from airflow import DAG
 from airflow.decorators import task
-from tc_hivemind_backend.ingest_qdrant import CustomIngestionPipeline
 from hivemind_etl_helpers.src.db.gdrive.gdrive_loader import GoogleDriveLoader
 from hivemind_etl_helpers.src.utils.modules import ModulesGDrive
+from tc_hivemind_backend.ingest_qdrant import CustomIngestionPipeline
 
 with DAG(
     dag_id="gdrive_vector_store",

dags/hivemind_telegram_etl.py

@@ -5,7 +5,6 @@
 from airflow import DAG
 from airflow.decorators import task
 from dotenv import load_dotenv
-from tc_hivemind_backend.ingest_qdrant import CustomIngestionPipeline
 from hivemind_etl_helpers.src.db.telegram.extract import (
     ExtractMessages,
     ExtractMessagesDaily,
@@ -18,6 +17,7 @@
 )
 from hivemind_etl_helpers.src.db.telegram.utils import TelegramModules, TelegramPlatform
 from qdrant_client.http import models
+from tc_hivemind_backend.ingest_qdrant import CustomIngestionPipeline
 
 # Common DAG configuration
 default_args = {

dags/violation_detection_helpers/extract.py

@@ -1,8 +1,8 @@
 import logging
 from datetime import datetime
 
-from tc_hivemind_backend.db.mongo import MongoSingleton
 from pymongo.cursor import Cursor
+from tc_hivemind_backend.db.mongo import MongoSingleton
 
 
 class ExtractPlatformRawData:

dags/violation_detection_helpers/load.py

@@ -1,7 +1,7 @@
 from typing import Any
 
-from tc_hivemind_backend.db.mongo import MongoSingleton
 from pymongo import UpdateOne
+from tc_hivemind_backend.db.mongo import MongoSingleton
 
 
 class LoadPlatformLabeledData: