Skip to content

Commit 738ad55

Browse files
committed
Revert "create fixture for creating rabbitmq rpc server"
This reverts commit c8d9b01.
1 parent 1202074 commit 738ad55

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-
rabbitmq_rpc_client: Callable[[str], Awaitable[RabbitMQRPCClient]],
119+
rpc_client: Callable[[str], Awaitable[RabbitMQRPCClient]],
120120
) -> RabbitMQRPCClient:
121-
client = await rabbitmq_rpc_client("celery_test_client")
121+
client = await rpc_client("celery_test_client")
122122
await client.register_router(router, STORAGE_RPC_NAMESPACE)
123123
return client
124124

0 commit comments

Comments
 (0)