Skip to content

Commit c8d9b01

Browse files
committed
create fixture for creating rabbitmq rpc server
1 parent 58e7fa1 commit c8d9b01

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

packages/celery-library/tests/unit/test_async_jobs.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -116,9 +116,9 @@ async def async_job(task: Task, task_id: TaskID, action: Action, payload: Any) -
116116

117117
@pytest.fixture
118118
async def rpc_client(
119-
rpc_client: Callable[[str], Awaitable[RabbitMQRPCClient]],
119+
rabbitmq_rpc_client: Callable[[str], Awaitable[RabbitMQRPCClient]],
120120
) -> RabbitMQRPCClient:
121-
client = await rpc_client("celery_test_client")
121+
client = await rabbitmq_rpc_client("celery_test_client")
122122
await client.register_router(router, STORAGE_RPC_NAMESPACE)
123123
return client
124124

0 commit comments

Comments
 (0)