rename

Author: giancarloromeo

packages/celery-library/src/celery_library/signals.py

@@ -30,7 +30,7 @@ def _init(startup_complete_event: threading.Event) -> None:
 
         app_server.event_loop = loop
 
-        loop.run_until_complete(app_server.start_and_hold(startup_complete_event))
+        loop.run_until_complete(app_server.run_until_shutdown(startup_complete_event))
 
     thread = threading.Thread(
         group=None,

packages/celery-library/tests/conftest.py

@@ -52,7 +52,9 @@ def task_manager(self) -> TaskManager:
         assert self._task_manager, "Task manager is not initialized"
         return self._task_manager
 
-    async def start_and_hold(self, startup_completed_event: threading.Event) -> None:
+    async def run_until_shutdown(
+        self, startup_completed_event: threading.Event
+    ) -> None:
         redis_client_sdk = RedisClientSDK(
             self._settings.CELERY_REDIS_RESULT_BACKEND.build_redis_dsn(
                 RedisDatabase.CELERY_TASKS

packages/service-library/src/servicelib/celery/app_server.py

@@ -36,7 +36,7 @@ def task_manager(self) -> TaskManager:
         raise NotImplementedError
 
     @abstractmethod
-    async def start_and_hold(
+    async def run_until_shutdown(
         self,
         startup_completed_event: threading.Event,
     ) -> None:

packages/service-library/src/servicelib/fastapi/celery/app_server.py

@@ -22,7 +22,9 @@ def task_manager(self) -> TaskManager:
         assert isinstance(task_manager, TaskManager)
         return task_manager
 
-    async def start_and_hold(self, startup_completed_event: threading.Event) -> None:
+    async def run_until_shutdown(
+        self, startup_completed_event: threading.Event
+    ) -> None:
         async with LifespanManager(
             self.app,
             startup_timeout=None,  # waits for full app initialization (DB migrations, etc.)