Trying to fix thread leak: maybe some async will help?

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)