We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7cfffd7 commit 75dc910Copy full SHA for 75dc910
services/storage/tests/unit/test_async_jobs.py
@@ -277,6 +277,14 @@ async def test_async_jobs_cancel(
277
job_id_data=job_id_data,
278
)
279
280
+ jobs = await async_jobs.list_jobs(
281
+ storage_rabbitmq_rpc_client,
282
+ rpc_namespace=STORAGE_RPC_NAMESPACE,
283
+ filter_="", # currently not used
284
+ job_id_data=job_id_data,
285
+ )
286
+ assert async_job_get.job_id not in [job.job_id for job in jobs]
287
+
288
with pytest.raises(JobAbortedError):
289
await async_jobs.result(
290
storage_rabbitmq_rpc_client,
0 commit comments