diff --git a/services/storage/tests/conftest.py b/services/storage/tests/conftest.py index 9a41a2a73496..e657418a79f4 100644 --- a/services/storage/tests/conftest.py +++ b/services/storage/tests/conftest.py @@ -1018,12 +1018,8 @@ async def with_storage_celery_worker_controller( perform_ping_check=False, queues="default,cpu_bound", ) as worker: - worker_init.send(sender=worker) - yield worker - worker_shutdown.send(sender=worker) - @pytest.fixture def with_storage_celery_worker( diff --git a/services/storage/tests/unit/test_async_jobs.py b/services/storage/tests/unit/test_async_jobs.py index e45bff4a63c1..89bebdadea0c 100644 --- a/services/storage/tests/unit/test_async_jobs.py +++ b/services/storage/tests/unit/test_async_jobs.py @@ -195,7 +195,7 @@ async def _wait_for_job( {"a", "set"}, ], ) -async def test_asybc_jobs_workflow( +async def test_async_jobs_workflow( initialized_app: FastAPI, register_rpc_routes: None, storage_rabbitmq_rpc_client: RabbitMQRPCClient, @@ -241,15 +241,7 @@ async def test_asybc_jobs_workflow( "exposed_rpc_start", [ rpc_sync_job.__name__, - pytest.param( - rpc_async_job.__name__, - marks=pytest.mark.skip( - reason=( - "hangs after teardown for unknown reason " - "SEE https://github.com/ITISFoundation/osparc-simcore/issues/7486" - ) - ), - ), + rpc_async_job.__name__, ], ) async def test_async_jobs_cancel(