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 0bd2df3 commit 84a64fcCopy full SHA for 84a64fc
packages/service-library/src/servicelib/rabbitmq/rpc_interfaces/async_jobs/async_jobs.py
@@ -238,7 +238,7 @@ async def wait_and_get_result(
238
)
239
except (TimeoutError, CancelledError) as error:
240
try:
241
- await abort(
+ await cancel(
242
rabbitmq_rpc_client,
243
rpc_namespace=rpc_namespace,
244
job_id=job_id,
@@ -270,7 +270,7 @@ async def submit_and_wait(
270
271
if async_job_rpc_get is not None:
272
273
274
275
276
job_id=async_job_rpc_get.job_id,
0 commit comments