From bd40cd1e2cf66978a7d1f50f45ebe7b1609031b8 Mon Sep 17 00:00:00 2001 From: Hilary James Oliver Date: Tue, 9 Jan 2024 11:17:48 +1300 Subject: [PATCH] Don't delete xtriggers table before every update. --- cylc/flow/rundb.py | 2 ++ cylc/flow/workflow_db_mgr.py | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/cylc/flow/rundb.py b/cylc/flow/rundb.py index 84360083c5c..256da3b3129 100644 --- a/cylc/flow/rundb.py +++ b/cylc/flow/rundb.py @@ -298,6 +298,8 @@ class CylcWorkflowDAO: ["prereq_output", {"is_primary_key": True}], ["satisfied"], ], + # The xtriggers table holds the function signature and result of + # already-satisfied (the scheduler no longer needs to call them). TABLE_XTRIGGERS: [ ["signature", {"is_primary_key": True}], ["results"], diff --git a/cylc/flow/workflow_db_mgr.py b/cylc/flow/workflow_db_mgr.py index 091d1712429..83c4b9c7be9 100644 --- a/cylc/flow/workflow_db_mgr.py +++ b/cylc/flow/workflow_db_mgr.py @@ -404,7 +404,7 @@ def put_task_event_timers(self, task_events_mgr): def put_xtriggers(self, sat_xtrig): """Put statements to update external triggers table.""" - self.db_deletes_map[self.TABLE_XTRIGGERS].append({}) + # self.db_deletes_map[self.TABLE_XTRIGGERS].append({}) for sig, res in sat_xtrig.items(): self.db_inserts_map[self.TABLE_XTRIGGERS].append({ "signature": sig,