optimize

ITISFoundation · Jan 19, 2024 · 01ec040 · 01ec040
1 parent 82bd91f
commit 01ec040
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/...ices/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/dask_scheduler.py b/...ices/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/dask_scheduler.py
@@ -132,11 +132,15 @@ async def _start_tasks(
             )
 
             # update the database so we do have the correct job_ids there
-            for task_sents in results:
-                for task in task_sents:
-                    await comp_tasks_repo.update_project_task_job_id(
+            await asyncio.gather(
+                *(
+                    comp_tasks_repo.update_project_task_job_id(
                         project_id, task.node_id, task.job_id
                     )
+                    for task_sents in results
+                    for task in task_sents
+                )
+            )
 
     async def _get_tasks_status(
         self,