Skip to content

Commit b8ba58a

Browse files
committed
Tweak xtrigger logging.
1 parent f189d6e commit b8ba58a

File tree

2 files changed

+5
-0
lines changed

2 files changed

+5
-0
lines changed

changes.d/7026.fix.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
Log (re)commencement of xtrigger calls, for old xtriggers.

cylc/flow/xtrigger_mgr.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -711,6 +711,7 @@ def call_xtriggers_async(self, itask: 'TaskProxy'):
711711
# General case: potentially slow asynchronous function call.
712712
if sig in self.sat_xtrig:
713713
# Already satisfied, just update the task
714+
LOG.info(f"[{itask}] satisfying xtrigger prerequisite: {sig}")
714715
if not itask.state.xtriggers[label]:
715716
itask.state.xtriggers[label] = True
716717
res = {}
@@ -760,7 +761,10 @@ def housekeep(self, itasks):
760761
itask, sigs_only=True, unsat_only=True)
761762
for sig in list(self.sat_xtrig):
762763
if sig not in all_xtrig:
764+
LOG.debug(f"Housekeeping xtrigger result: {sig}")
763765
del self.sat_xtrig[sig]
766+
with suppress(KeyError):
767+
del self.t_next_call[sig]
764768
self.do_housekeeping = False
765769

766770
def all_task_seq_xtriggers_satisfied(self, itask: 'TaskProxy') -> bool:

0 commit comments

Comments
 (0)