force shutdown

Author: giancarloromeo

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

@@ -34,3 +34,4 @@ async def run_until_shutdown(
             _logger.info("FastAPI initialized: %s", self.app)
             startup_completed_event.set()
             await self.shutdown_event.wait()  # NOTE: wait here until shutdown is requested
+            _logger.info("FastAPI shutdown completed: %s", self.app)

services/storage/tests/conftest.py

@@ -23,7 +23,7 @@
 from aws_library.s3 import SimcoreS3API
 from celery import Celery
 from celery.contrib.testing.worker import TestWorkController, start_worker
-from celery.signals import worker_init, worker_shutdown
+from celery.signals import worker_init
 from celery_library.worker.signals import _worker_init_wrapper, _worker_shutdown_wrapper
 from faker import Faker
 from fakeredis.aioredis import FakeRedis
@@ -1040,7 +1040,7 @@ async def with_storage_celery_worker(
         _worker_init_wrapper(celery_app, app_server_factory_with_worker_mode),
         weak=False,
     )
-    worker_shutdown.connect(_worker_shutdown_wrapper(celery_app), weak=False)
+    # worker_shutdown.connect(_worker_shutdown_wrapper(celery_app), weak=False)
 
     register_worker_tasks(celery_app)
     register_test_tasks(celery_app)
@@ -1055,6 +1055,8 @@ async def with_storage_celery_worker(
     ) as worker:
         yield worker
 
+        _worker_shutdown_wrapper(celery_app)()
+
 
 @pytest.fixture
 async def storage_rabbitmq_rpc_client(