Skip to content

Commit eab796f

Browse files
fix test
1 parent ec59035 commit eab796f

File tree

1 file changed

+0
-24
lines changed

1 file changed

+0
-24
lines changed

services/storage/tests/unit/test_async_jobs.py

Lines changed: 0 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -282,30 +282,6 @@ async def test_async_jobs_cancel(
282282
job_id_data=job_id_data,
283283
)
284284

285-
async_job_get, job_id_data = await _start_task_via_rpc(
286-
storage_rabbitmq_rpc_client,
287-
rpc_task_name=exposed_rpc_start,
288-
user_id=user_id,
289-
product_name=product_name,
290-
action=Action.ECHO,
291-
payload="bla",
292-
)
293-
294-
await _wait_for_job(
295-
storage_rabbitmq_rpc_client,
296-
async_job_get=async_job_get,
297-
job_id_data=job_id_data,
298-
stop_after=timedelta(seconds=15),
299-
)
300-
301-
async_job_result = await async_jobs.result(
302-
storage_rabbitmq_rpc_client,
303-
rpc_namespace=STORAGE_RPC_NAMESPACE,
304-
job_id=async_job_get.job_id,
305-
job_id_data=job_id_data,
306-
)
307-
assert async_job_result.result == "bla"
308-
309285

310286
@pytest.mark.parametrize(
311287
"exposed_rpc_start",

0 commit comments

Comments
 (0)