hold spawn on multi seq xtrigs

cylc · Feb 21, 2024 · 6c5c07c · 6c5c07c
1 parent f44e018
commit 6c5c07c
Showing 1 changed file with 16 additions and 2 deletions.
diff --git a/cylc/flow/xtrigger_mgr.py b/cylc/flow/xtrigger_mgr.py
@@ -520,7 +520,14 @@ def call_xtriggers_async(self, itask: 'TaskProxy'):
                     self.data_store_mgr.delta_task_xtrigger(sig, True)
                     self.workflow_db_mgr.put_xtriggers({sig: {}})
                     LOG.info('xtrigger satisfied: %s = %s', label, sig)
-                    if itask.is_xtrigger_sequential:
+                    if (
+                        itask.is_xtrigger_sequential
+                        and all(
+                            itask.state.xtriggers[seq_label]
+                            for seq_label in itask.state.xtriggers
+                            if seq_label in self.sequential_xtrigger_labels
+                        )
+                    ):
                         self.sequential_spawn_next.add(itask.identity)
                     self.do_housekeeping = True
                 continue
@@ -540,7 +547,14 @@ def call_xtriggers_async(self, itask: 'TaskProxy'):
                             [itask.tdef.name],
                             xtrigger_env
                         )
-                    if itask.is_xtrigger_sequential:
+                    if (
+                        itask.is_xtrigger_sequential
+                        and all(
+                            itask.state.xtriggers[seq_label]
+                            for seq_label in itask.state.xtriggers
+                            if seq_label in self.sequential_xtrigger_labels
+                        )
+                    ):
                         self.sequential_spawn_next.add(itask.identity)
                 continue