diff --git a/chain_service/dependencies/audio_converter_service.py b/chain_service/dependencies/audio_converter_service.py index f0a96c4..799fc19 100644 --- a/chain_service/dependencies/audio_converter_service.py +++ b/chain_service/dependencies/audio_converter_service.py @@ -1,5 +1,5 @@ from chain_service.services.audio_converter import AudioConverterService -def get_audio_converter_service() -> AudioConverterService: +async def get_audio_converter_service() -> AudioConverterService: return AudioConverterService() diff --git a/chain_service/dependencies/chain_repository.py b/chain_service/dependencies/chain_repository.py index 9850d65..824ef91 100644 --- a/chain_service/dependencies/chain_repository.py +++ b/chain_service/dependencies/chain_repository.py @@ -5,5 +5,5 @@ from fastapi import Depends from typing import Annotated -def get_chain_repository(database: Annotated[Database, Depends(get_database)]) -> ChainRepository: +async def get_chain_repository(database: Annotated[Database, Depends(get_database)]) -> ChainRepository: return ChainRepository(database=database) diff --git a/chain_service/dependencies/database.py b/chain_service/dependencies/database.py index 49044b7..5b95e34 100644 --- a/chain_service/dependencies/database.py +++ b/chain_service/dependencies/database.py @@ -2,7 +2,7 @@ from chain_service.settings import Settings from chain_service.database.database import Database -def get_database() -> Database: +async def get_database() -> Database: settings = Settings() return Database( diff --git a/chain_service/dependencies/file_uploader_service.py b/chain_service/dependencies/file_uploader_service.py index bc3a4cf..d722366 100644 --- a/chain_service/dependencies/file_uploader_service.py +++ b/chain_service/dependencies/file_uploader_service.py @@ -13,7 +13,7 @@ from chain_service.repositories.uploaded_file import UploadedFileRepository from chain_service.services.audio_converter import AudioConverterService -def get_file_uploader_service( +async def get_file_uploader_service( planfix_client: Annotated[PlanfixClient, Depends(get_planfix_client)], uploaded_file_repository: Annotated[UploadedFileRepository, Depends(get_uploaded_file_repository)], audio_converter_service: Annotated[AudioConverterService, Depends(get_audio_converter_service)], diff --git a/chain_service/dependencies/namespace_repository.py b/chain_service/dependencies/namespace_repository.py index f276ae6..7c2d80d 100644 --- a/chain_service/dependencies/namespace_repository.py +++ b/chain_service/dependencies/namespace_repository.py @@ -7,5 +7,5 @@ from fastapi import Depends from typing import Annotated -def get_namespace_repository(database: Annotated[Database, Depends(get_database)]) -> NamespaceRepository: +async def get_namespace_repository(database: Annotated[Database, Depends(get_database)]) -> NamespaceRepository: return NamespaceRepository(database=database) diff --git a/chain_service/dependencies/planfix_client.py b/chain_service/dependencies/planfix_client.py index b418391..f1277b7 100644 --- a/chain_service/dependencies/planfix_client.py +++ b/chain_service/dependencies/planfix_client.py @@ -2,7 +2,7 @@ from planfix_client import PlanfixClient from chain_service.settings import Settings -def get_planfix_client() -> PlanfixClient: +async def get_planfix_client() -> PlanfixClient: settings = Settings() return PlanfixClient( diff --git a/chain_service/dependencies/progress_action_service_factory.py b/chain_service/dependencies/progress_action_service_factory.py index b5fd4b3..54f7800 100644 --- a/chain_service/dependencies/progress_action_service_factory.py +++ b/chain_service/dependencies/progress_action_service_factory.py @@ -12,7 +12,7 @@ from typing import Annotated from chain_service.repositories.uploaded_file import UploadedFileRepository -def get_progress_action_service_factory( +async def get_progress_action_service_factory( planfix_client: Annotated[PlanfixClient, Depends(get_planfix_client)], uploaded_file_repository: Annotated[UploadedFileRepository, Depends(get_uploaded_file_repository)] ) -> ProgressActionServiceFactory: diff --git a/chain_service/dependencies/progress_chain_repository.py b/chain_service/dependencies/progress_chain_repository.py index 66ae3de..f2770ad 100644 --- a/chain_service/dependencies/progress_chain_repository.py +++ b/chain_service/dependencies/progress_chain_repository.py @@ -6,7 +6,7 @@ from fastapi import Depends from typing import Annotated -def get_progress_chain_repository( +async def get_progress_chain_repository( database: Annotated[Database, Depends(get_database)], ) -> ProgressChainRepository: return ProgressChainRepository(database=database) diff --git a/chain_service/dependencies/progress_chain_runner_service.py b/chain_service/dependencies/progress_chain_runner_service.py index e2560ea..a989d63 100644 --- a/chain_service/dependencies/progress_chain_runner_service.py +++ b/chain_service/dependencies/progress_chain_runner_service.py @@ -12,7 +12,7 @@ from chain_service.repositories.running_chain import RunningChainRepository from chain_service.services.progress_action.factory import ProgressActionServiceFactory -def get_progress_chain_runner_service( +async def get_progress_chain_runner_service( progress_chain_repository: Annotated[ProgressChainRepository, Depends(get_progress_chain_repository)], progress_action_service_factory: Annotated[ProgressActionServiceFactory, Depends(get_progress_action_service_factory)], running_chain_repository: Annotated[RunningChainRepository, Depends(get_running_chain_repository)], diff --git a/chain_service/dependencies/running_chain_repository.py b/chain_service/dependencies/running_chain_repository.py index bb248f6..d2550dc 100644 --- a/chain_service/dependencies/running_chain_repository.py +++ b/chain_service/dependencies/running_chain_repository.py @@ -6,7 +6,7 @@ from fastapi import Depends from typing import Annotated -def get_running_chain_repository( +async def get_running_chain_repository( database: Annotated[Database, Depends(get_database)], ) -> RunningChainRepository: return RunningChainRepository(database=database) diff --git a/chain_service/dependencies/uploaded_file_repository.py b/chain_service/dependencies/uploaded_file_repository.py index eb313fd..3979ba5 100644 --- a/chain_service/dependencies/uploaded_file_repository.py +++ b/chain_service/dependencies/uploaded_file_repository.py @@ -6,7 +6,7 @@ from fastapi import Depends from typing import Annotated -def get_uploaded_file_repository( +async def get_uploaded_file_repository( database: Annotated[Database, Depends(get_database)], ) -> UploadedFileRepository: return UploadedFileRepository(database=database)