Skip to content

Commit 4ddb842

Browse files
committed
make the call async
1 parent 7700a78 commit 4ddb842

File tree

1 file changed

+1
-1
lines changed
  • services/director-v2/src/simcore_service_director_v2/modules

1 file changed

+1
-1
lines changed

services/director-v2/src/simcore_service_director_v2/modules/dask_client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -506,7 +506,7 @@ async def release_task_result(self, job_id: str) -> None:
506506
# the variable was effectively deleted.
507507
# This is annoying as one can re-create the variable without error.
508508
var = distributed.Variable(job_id, client=self.backend.client)
509-
var.delete()
509+
await asyncio.get_event_loop().run_in_executor(None, var.delete)
510510
# first check if the key exists
511511
await dask_utils.wrap_client_async_routine(
512512
self.backend.client.get_dataset(name=job_id)

0 commit comments

Comments
 (0)