lint fixes

Author: narang-an

archive/backend/app/core/neo4j.py

@@ -1,8 +1,9 @@
 # app/core/neo4j.py
 import os
+
 from app.repositories.graph_repository import GraphRepository
 
-_graph_repo: GraphRepository 
+_graph_repo: GraphRepository
 
 
 def get_graph_repo() -> GraphRepository | None:
@@ -27,4 +28,4 @@ def get_graph_repo() -> GraphRepository | None:
         return _graph_repo
     except Exception as e:
         print(f"Neo4j not available: {e}", flush=True)
-        return None
+        return None

backend/app/api.py

@@ -1,12 +1,12 @@
-from fastapi import APIRouter, Depends
-from supabase._async.client import AsyncClient
-
 from app.core.supabase import get_async_supabase
 from app.routes.classification_routes import router as classification_router
 from app.routes.migration_routes import router as migration_router
 from app.routes.pattern_recognition_routes import router as pattern_recognition_router
 from app.routes.preprocess_routes import router as preprocess_router
 from app.routes.search_routes import router as search_router
+from fastapi import APIRouter, Depends
+from supabase._async.client import AsyncClient
+
 from app.routes.documents import router as documents_router
 
 api_router = APIRouter(prefix="/api")

backend/app/cognee_config.py

@@ -1,4 +1,5 @@
 import os
+
 from cognee import configure
 
 _cognee_initialized: bool = False
@@ -14,7 +15,7 @@ async def setup_cognee() -> None:
     llm_model = os.getenv("LLM_MODEL")
     llm_api_key = os.getenv("LLM_API_KEY")
 
-    # Embeddings 
+    # Embeddings
     embedding_provider = os.getenv("EMBEDDING_PROVIDER")
     embedding_model = os.getenv("EMBEDDING_MODEL")
     embedding_api_key = os.getenv("EMBEDDING_API_KEY")

backend/app/main.py

@@ -21,12 +21,13 @@
     )
 
 
-from app.api import api_router  # noqa: E402
 from app.core.supabase import get_async_supabase  # noqa: E402
 from app.core.webhooks import configure_webhooks  # noqa: E402
 from app.services.extraction.preprocessing_queue import init_queue  # noqa: E402
 from app.services.supabase_check import wait_for_supabase  # noqa: E402
-from app.cognee_config import setup_cognee 
+
+from app.api import api_router  # noqa: E402
+from app.cognee_config import setup_cognee
 
 
 @asynccontextmanager

backend/tests/test_cognee.py

@@ -1,14 +1,17 @@
 from dotenv import load_dotenv
+
 load_dotenv(override=True)
 
-import cognee
 import asyncio
+
+import cognee
 from cognee.api.v1.search import SearchType
 
+
 async def setup_cognee():
     """Initialize cognee environment."""
     pass
-    
+
 async def ingest_document(files):
     """Ingest documents"""
     for file in files:
@@ -41,7 +44,7 @@ async def search_knowledge_graph():
 
 async def main():
     files = ["mock_data/DeepFryer-1.pdf", "mock_data/DeepFryer-2.pdf"]
-    
+
     await setup_cognee()
     await ingest_document(files)
 
@@ -68,4 +71,4 @@ async def main():
     await cognee.prune.prune_system(graph=True, vector=True, metadata=False)
 
 if __name__ == '__main__':
-    asyncio.run(main())
+    asyncio.run(main())

delete_retry_container.py

@@ -1,6 +1,5 @@
 
 import asyncio
-import os
 from supabase._async.client import create_client
 
 # Local Supabase credentials inside Docker or accessible from within