the variable shall be removed as well

sanderegg · sanderegg · commit f8844e463632 · 2024-12-05T14:27:34.000+01:00
diff --git a/services/director-v2/src/simcore_service_director_v2/modules/dask_client.py b/services/director-v2/src/simcore_service_director_v2/modules/dask_client.py
@@ -535,6 +535,7 @@ async def release_task_result(self, job_id: str) -> None:
             await dask_utils.wrap_client_async_routine(
                 self.backend.client.unpublish_dataset(name=job_id)
             )
+            distributed.Variable(job_id, client=self.backend.client).delete()
         except KeyError:
             _logger.warning("Unknown task cannot be unpublished: %s", f"{job_id=}")
 

Original file line number	Diff line number	Diff line change
`@@ -535,6 +535,7 @@ async def release_task_result(self, job_id: str) -> None:`
`535`	`535`	`await dask_utils.wrap_client_async_routine(`
`536`	`536`	`self.backend.client.unpublish_dataset(name=job_id)`
`537`	`537`	`)`
	`538`	`+ distributed.Variable(job_id, client=self.backend.client).delete()`
`538`	`539`	`except KeyError:`
`539`	`540`	`_logger.warning("Unknown task cannot be unpublished: %s", f"{job_id=}")`
`540`	`541`