Skip to content

Commit 716880d

Browse files
committed
get the tasks after the update from the backend
1 parent f4e5d21 commit 716880d

File tree

1 file changed

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

1 file changed

+3
-1
lines changed

services/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/_scheduler_base.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -636,11 +636,13 @@ async def apply(
636636
user_id, project_id, iteration
637637
)
638638
dag = await self._get_pipeline_dag(project_id)
639-
comp_tasks = await self._get_pipeline_tasks(project_id, dag)
639+
640640
# 1. Update our list of tasks with data from backend (state, results)
641641
await self._update_states_from_comp_backend(
642642
user_id, project_id, iteration, dag, comp_run
643643
)
644+
# 1.bis get the updated tasks NOTE: we need to get them again as some states might have changed
645+
comp_tasks = await self._get_pipeline_tasks(project_id, dag)
644646
# 2. timeout if waiting for cluster has been there for more than X minutes
645647
comp_tasks = await self._timeout_if_waiting_for_cluster_too_long(
646648
user_id, project_id, comp_run, comp_tasks

0 commit comments

Comments
 (0)