File tree Expand file tree Collapse file tree 4 files changed +4
-4
lines changed
service-library/src/servicelib Expand file tree Collapse file tree 4 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -30,7 +30,7 @@ def _init(startup_complete_event: threading.Event) -> None:
3030
3131 app_server .event_loop = loop
3232
33- loop .run_until_complete (app_server .lifespan (startup_complete_event ))
33+ loop .run_until_complete (app_server .start_and_hold (startup_complete_event ))
3434
3535 thread = threading .Thread (
3636 group = None ,
Original file line number Diff line number Diff line change @@ -46,7 +46,7 @@ def task_manager(self) -> TaskManager:
4646 assert self ._task_manager , "Task manager is not initialized"
4747 return self ._task_manager
4848
49- async def lifespan (self , startup_completed_event : threading .Event ) -> None :
49+ async def start_and_hold (self , startup_completed_event : threading .Event ) -> None :
5050 redis_client_sdk = RedisClientSDK (
5151 self ._settings .CELERY_REDIS_RESULT_BACKEND .build_redis_dsn (
5252 RedisDatabase .CELERY_TASKS
Original file line number Diff line number Diff line change @@ -36,7 +36,7 @@ def task_manager(self) -> TaskManager:
3636 raise NotImplementedError
3737
3838 @abstractmethod
39- async def lifespan (
39+ async def start_and_hold (
4040 self ,
4141 startup_completed_event : threading .Event ,
4242 ) -> None :
Original file line number Diff line number Diff line change @@ -25,7 +25,7 @@ def task_manager(self) -> TaskManager:
2525 task_manager : TaskManager = self .app .state .task_manager
2626 return task_manager
2727
28- async def lifespan (self , startup_completed_event : threading .Event ) -> None :
28+ async def start_and_hold (self , startup_completed_event : threading .Event ) -> None :
2929 async with LifespanManager (
3030 self .app ,
3131 startup_timeout = None , # waits for full app initialization (DB migrations, etc.)
You can’t perform that action at this time.
0 commit comments