From 53e5fcc674babf9cf6d5d9f6c939e3f608f1c578 Mon Sep 17 00:00:00 2001 From: David Sutherland Date: Fri, 18 Jul 2025 16:28:58 +1200 Subject: [PATCH] (no) Pre batch processing task state (Option 3) --- cylc/flow/data_store_mgr.py | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/cylc/flow/data_store_mgr.py b/cylc/flow/data_store_mgr.py index f8fe824c97..55c2f6370a 100644 --- a/cylc/flow/data_store_mgr.py +++ b/cylc/flow/data_store_mgr.py @@ -1143,6 +1143,9 @@ def increment_graph_window( self.prune_trigger_nodes[active_id]) del self.prune_trigger_nodes[active_id] + # load database history for flagged nodes + self.apply_task_proxy_db_history() + def generate_edge( self, parent_tokens: Tokens, @@ -1284,8 +1287,6 @@ def generate_ghost_task( depth=task_def.depth, graph_depth=n_depth, name=name, - # Set default before history DB batch application - flow_nums=serialise_set(set()), ) self.all_n_window_nodes.add(tp_id) self.n_window_depths.setdefault(n_depth, set()).add(tp_id) @@ -1777,9 +1778,6 @@ def update_data_structure(self): self.window_resize_rewalk() self.next_n_edge_distance = None - # load database history for flagged nodes - self.apply_task_proxy_db_history() - self.updates_pending_follow_on = False self.prune_data_store()