Skip to content

Commit af14f42

Browse files
committed
Update datastore xtriggers on restart.
1 parent a411aae commit af14f42

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

cylc/flow/xtrigger_mgr.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -574,6 +574,8 @@ def load_xtrigger_for_restart(self, row_idx: int, row: Tuple[str, str]):
574574
LOG.info("LOADING satisfied xtriggers")
575575
sig, results = row
576576
self.sat_xtrig[sig] = json.loads(results)
577+
# Tell the datastore this xtrigger is satisfied.
578+
self.data_store_mgr.delta_task_xtrigger(sig, True)
577579

578580
def _get_xtrigs(self, itask: 'TaskProxy', unsat_only: bool = False,
579581
sigs_only: bool = False):

0 commit comments

Comments
 (0)