From 13866e32db094020a6dc8c2d4a8eec0c3aaa63b5 Mon Sep 17 00:00:00 2001 From: Kabir Vats Date: Mon, 15 Dec 2025 14:39:34 -0700 Subject: [PATCH] quick fix hope --- beeflow/wf_manager/resources/wf_update.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/beeflow/wf_manager/resources/wf_update.py b/beeflow/wf_manager/resources/wf_update.py index 73626ceae..85c956a56 100644 --- a/beeflow/wf_manager/resources/wf_update.py +++ b/beeflow/wf_manager/resources/wf_update.py @@ -143,6 +143,9 @@ def handle_checkpoint_restart(self, state_update, task, wfi): def handle_state_change(self, state_update, task, wfi): """Handle a normal state change for a task.""" wf_id = wfi.workflow_id + if state_update.job_state == wfi.get_task_state(task.id): + log.info(f"Received duplicate state update for task {task.name}; ignoring.") + return wf_state = wf_utils.get_wf_status(wf_id) if state_update.job_state == 'COMPLETED': for output in task.outputs: