mirror/hatchet
1
0
Fork 0
mirror of https://github.com/hatchet-dev/hatchet.git synced 2026-01-06 08:49:53 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix: match and cancel newest/in progress deadlocks (#2190)

Browse Source
This commit is contained in:
abelanger5
2025-08-25 12:54:08 -04:00
committed by GitHub
parent 8464cb3412
commit 2a8ba155fa
9 changed files with 476 additions and 59 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
sql/schema/v1-core.sql
View File

@@ -1086,17 +1086,6 @@ BEGIN
FROM new_table
ON CONFLICT (external_id) DO NOTHING;
-- NOTE: this comes after the insert into v1_dag_to_task and v1_lookup_table, because we case on these tables for cleanup
FOR rec IN SELECT UNNEST(concurrency_parent_strategy_ids) AS parent_strategy_id, workflow_version_id, workflow_run_id FROM new_table WHERE initial_state != 'QUEUED' ORDER BY parent_strategy_id, workflow_version_id, workflow_run_id LOOP
IF rec.parent_strategy_id IS NOT NULL THEN
PERFORM cleanup_workflow_concurrency_slots(
rec.parent_strategy_id,
rec.workflow_version_id,
rec.workflow_run_id
);
END IF;
END LOOP;
RETURN NULL;
END;
$$