Skip to content

Commit daec075

Browse files
author
Andrei Neagu
committed
using proper interface
1 parent 78836a6 commit daec075

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

services/storage/tests/conftest.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,6 +75,7 @@
7575
on_worker_init,
7676
on_worker_shutdown,
7777
)
78+
from simcore_service_storage.modules.celery.utils import get_celery_worker
7879
from simcore_service_storage.modules.celery.worker import CeleryTaskQueueWorker
7980
from simcore_service_storage.modules.s3 import get_s3_client
8081
from simcore_service_storage.simcore_s3_dsm import SimcoreS3DataManager
@@ -1028,7 +1029,7 @@ def with_storage_celery_worker(
10281029
with_storage_celery_worker_controller: TestWorkController,
10291030
) -> CeleryTaskQueueWorker:
10301031
assert isinstance(with_storage_celery_worker_controller.app, Celery)
1031-
return CeleryTaskQueueWorker(with_storage_celery_worker_controller.app)
1032+
return get_celery_worker(with_storage_celery_worker_controller.app)
10321033

10331034

10341035
@pytest.fixture

0 commit comments

Comments
 (0)