fix: add wait after submit

giancarloromeo · giancarloromeo · commit 5198a3754f20 · 2025-08-22T12:30:50.000+02:00
diff --git a/packages/celery-library/tests/unit/test_async_jobs.py b/packages/celery-library/tests/unit/test_async_jobs.py
@@ -301,6 +301,8 @@ async def test_async_jobs_cancel(
         payload=60 * 10,  # test hangs if not cancelled properly
     )
 
+    await asyncio.sleep(3)
+
     await async_jobs.cancel(
         async_jobs_rabbitmq_rpc_client,
         rpc_namespace=ASYNC_JOBS_RPC_NAMESPACE,

Original file line number	Diff line number	Diff line change
`@@ -301,6 +301,8 @@ async def test_async_jobs_cancel(`
`301`	`301`	`payload=60 * 10, # test hangs if not cancelled properly`
`302`	`302`	`)`
`303`	`303`
	`304`	`+ await asyncio.sleep(3)`
	`305`	`+`
`304`	`306`	`await async_jobs.cancel(`
`305`	`307`	`async_jobs_rabbitmq_rpc_client,`
`306`	`308`	`rpc_namespace=ASYNC_JOBS_RPC_NAMESPACE,`