+ Some thread debugging

chain_service/app.py

@@ -1,13 +1,32 @@
-from chain_service.logging import setup_logging
+import logging
+import threading
 
 from fastapi import FastAPI
 from fastapi.middleware.cors import CORSMiddleware
+
+from chain_service.logging import setup_logging
 from chain_service.controllers.__main__ import setup_controllers
 
 setup_logging()
 
 application = FastAPI()
 
+logging.basicConfig(level=logging.DEBUG)
+
+
+# Subclass threading.Thread for logging
+class DebugThread(threading.Thread):
+    def __init__(self, *args, **kwargs):
+        logging.debug(f"Creating thread {args} {kwargs}")
+        super().__init__(*args, **kwargs)
+
+    def _delete(self):
+        logging.debug(f"Deleting thread {self.name}")
+        super()._delete()
+
+
+threading.Thread = DebugThread
+
 application.add_middleware(
     CORSMiddleware,
     allow_origins=["http://localhost:5173"],

chain_service/dependencies/audio_converter_service.py

@@ -4,7 +4,7 @@ from fastapi import Depends
 from typing import Annotated
 
 
-def get_audio_converter_service() -> AudioConverterService:
+async def get_audio_converter_service() -> AudioConverterService:
     return AudioConverterService()
 
 

chain_service/dependencies/chain_repository.py

@@ -5,7 +5,7 @@ from fastapi import Depends
 from typing import Annotated
 
 
-def get_chain_repository(database: DatabaseDependency) -> ChainRepository:
+async def get_chain_repository(database: DatabaseDependency) -> ChainRepository:
     return ChainRepository(database=database)
 
 

chain_service/dependencies/database.py

@@ -5,7 +5,7 @@ from fastapi import Depends
 from typing import Annotated
 
 
-def get_database() -> Database:
+async def get_database() -> Database:
     settings = Settings()
 
     return Database(

chain_service/dependencies/file_uploader_service.py

@@ -8,7 +8,7 @@ from fastapi import Depends
 from typing import Annotated
 
 
-def get_file_uploader_service(
+async def get_file_uploader_service(
     planfix_client: PlanfixClientDependency,
     uploaded_file_repository: UploadedFileRepositoryDependency,
     audio_converter_service: AudioConverterServiceDependency,

chain_service/dependencies/namespace_repository.py

@@ -6,7 +6,7 @@ from fastapi import Depends
 from typing import Annotated
 
 
-def get_namespace_repository(database: DatabaseDependency) -> NamespaceRepository:
+async def get_namespace_repository(database: DatabaseDependency) -> NamespaceRepository:
     return NamespaceRepository(database=database)
 
 

chain_service/dependencies/planfix_client.py

@@ -5,7 +5,7 @@ from fastapi import Depends
 from typing import Annotated
 
 
-def get_planfix_client() -> PlanfixClient:
+async def get_planfix_client() -> PlanfixClient:
     settings = Settings()
 
     return PlanfixClient(

chain_service/dependencies/progress_action_service_factory.py

@@ -9,7 +9,7 @@ from fastapi import Depends
 from typing import Annotated
 
 
-def get_progress_action_service_factory(
+async def get_progress_action_service_factory(
     planfix_client: PlanfixClientDependency,
     uploaded_file_repository: UploadedFileRepositoryDependency,
 ) -> ProgressActionServiceFactory:

chain_service/dependencies/progress_chain_repository.py

@@ -5,7 +5,7 @@ from fastapi import Depends
 from typing import Annotated
 
 
-def get_progress_chain_repository(
+async def get_progress_chain_repository(
     database: DatabaseDependency,
 ) -> ProgressChainRepository:
     return ProgressChainRepository(database=database)

chain_service/dependencies/progress_chain_runner_service.py

@@ -9,7 +9,7 @@ from fastapi import Depends
 from typing import Annotated
 
 
-def get_progress_chain_runner_service(
+async def get_progress_chain_runner_service(
     progress_chain_repository: ProgressChainRepositoryDependency,
     progress_action_service_factory: ProgressActionServiceFactoryDependency,
     running_chain_repository: RunningChainRepositoryDependency,

chain_service/dependencies/running_chain_repository.py

@@ -5,7 +5,7 @@ from fastapi import Depends
 from typing import Annotated
 
 
-def get_running_chain_repository(
+async def get_running_chain_repository(
     database: DatabaseDependency,
 ) -> RunningChainRepository:
     return RunningChainRepository(database=database)

chain_service/dependencies/uploaded_file_repository.py

@@ -5,7 +5,7 @@ from fastapi import Depends
 from typing import Annotated
 
 
-def get_uploaded_file_repository(
+async def get_uploaded_file_repository(
     database: DatabaseDependency,
 ) -> UploadedFileRepository:
     return UploadedFileRepository(database=database)