Skip to content

Commit bfa9879

Browse files
committed
refactor: improve mocking utilities for RPC interfaces in tests
1 parent 46e8db9 commit bfa9879

File tree

3 files changed

+113
-75
lines changed

3 files changed

+113
-75
lines changed

services/api-server/tests/unit/api_functions/celery/conftest.py

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -52,19 +52,18 @@ async def mocked_log_streamer_setup(mocker: MockerFixture) -> MockerFixture:
5252
# mock log streamer: He is looking for non-existent queues. Should be solved more elegantly
5353
from simcore_service_api_server.services_http import rabbitmq
5454

55-
mock_log_streamer = mocker.patch.object(rabbitmq, "LogDistributor", spec=True)
56-
return mock_log_streamer
55+
return mocker.patch.object(rabbitmq, "LogDistributor", spec=True)
5756

5857

5958
@pytest.fixture
6059
def mock_celery_app(mocker: MockerFixture, celery_config: dict[str, Any]) -> Celery:
6160
celery_app = Celery(**celery_config)
6261

63-
mocker.patch.object(
62+
mock = mocker.patch.object(
6463
celery_task_manager,
6564
celery_task_manager.create_app.__name__,
66-
lambda settings: celery_app,
6765
)
66+
mock.return_value = celery_app
6867

6968
return celery_app
7069

0 commit comments

Comments
 (0)