Skip to content

Commit 384a2a1

Browse files
committed
Revert "create fixture for creating rabbitmq rpc server"
This reverts commit c8d9b01.
1 parent 8b2e65c commit 384a2a1

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

services/storage/tests/unit/test_async_jobs.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@
3030
from models_library.users import UserID
3131
from servicelib.rabbitmq import RabbitMQRPCClient, RPCRouter
3232
from servicelib.rabbitmq.rpc_interfaces.async_jobs import async_jobs
33-
from simcore_service_storage.api.rpc.routes import get_rabbitmq_rpc_server
3433
from tenacity import (
3534
AsyncRetrying,
3635
retry_if_exception_type,
@@ -109,9 +108,12 @@ async def async_job(task: Task, task_id: TaskID, action: Action, payload: Any) -
109108

110109

111110
@pytest.fixture
112-
async def register_rpc_routes(initialized_app: FastAPI) -> None:
113-
rpc_server = get_rabbitmq_rpc_server(initialized_app)
114-
await rpc_server.register_router(router, STORAGE_RPC_NAMESPACE, initialized_app)
111+
async def rpc_client(
112+
rpc_client: Callable[[str], Awaitable[RabbitMQRPCClient]],
113+
) -> RabbitMQRPCClient:
114+
client = await rpc_client("celery_test_client")
115+
await client.register_router(router, STORAGE_RPC_NAMESPACE)
116+
return client
115117

116118

117119
async def _start_task_via_rpc(

0 commit comments

Comments
 (0)