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

fix: recursive queries should use PKs (#1345)

Browse Source
This commit is contained in:
abelanger5
2025-03-14 13:13:27 -04:00
committed by GitHub
parent 48fdc4a7b7
commit 7ad251df26
2 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
pkg/repository/v1/sqlcv1/tasks.sql
View File

@@ -628,6 +628,7 @@ WITH RECURSIVE augmented_tasks AS (
id,
tenant_id,
dag_id,
dag_inserted_at,
step_id
FROM
v1_task
@@ -646,15 +647,16 @@ WITH RECURSIVE augmented_tasks AS (
t.id,
t.tenant_id,
t.dag_id,
t.dag_inserted_at,
t.step_id
FROM
augmented_tasks at
JOIN
"Step" s1 ON s1."id" = at.step_id
JOIN
v1_dag_to_task dt ON dt.dag_id = at.dag_id
v1_dag_to_task dt ON dt.dag_id = at.dag_id AND dt.dag_inserted_at = at.dag_inserted_at
JOIN
v1_task t ON t.id = dt.task_id
v1_task t ON t.id = dt.task_id AND t.inserted_at = dt.task_inserted_at
JOIN
"Step" s2 ON s2."id" = t.step_id
JOIN
@@ -774,9 +776,9 @@ WITH RECURSIVE augmented_tasks AS (
JOIN
"Step" s1 ON s1."id" = at.step_id
JOIN
v1_dag_to_task dt ON dt.dag_id = at.dag_id
v1_dag_to_task dt ON dt.dag_id = at.dag_id AND dt.dag_inserted_at = at.dag_inserted_at
JOIN
v1_task t ON t.id = dt.task_id
v1_task t ON t.id = dt.task_id AND t.inserted_at = dt.task_inserted_at
JOIN
"Step" s2 ON s2."id" = t.step_id
JOIN

10
pkg/repository/v1/sqlcv1/tasks.sql.go
View File

@@ -794,9 +794,9 @@ WITH RECURSIVE augmented_tasks AS (
JOIN
"Step" s1 ON s1."id" = at.step_id
JOIN
v1_dag_to_task dt ON dt.dag_id = at.dag_id
v1_dag_to_task dt ON dt.dag_id = at.dag_id AND dt.dag_inserted_at = at.dag_inserted_at
JOIN
v1_task t ON t.id = dt.task_id
v1_task t ON t.id = dt.task_id AND t.inserted_at = dt.task_inserted_at
JOIN
"Step" s2 ON s2."id" = t.step_id
JOIN
@@ -957,6 +957,7 @@ WITH RECURSIVE augmented_tasks AS (
id,
tenant_id,
dag_id,
dag_inserted_at,
step_id
FROM
v1_task
@@ -975,15 +976,16 @@ WITH RECURSIVE augmented_tasks AS (
t.id,
t.tenant_id,
t.dag_id,
t.dag_inserted_at,
t.step_id
FROM
augmented_tasks at
JOIN
"Step" s1 ON s1."id" = at.step_id
JOIN
v1_dag_to_task dt ON dt.dag_id = at.dag_id
v1_dag_to_task dt ON dt.dag_id = at.dag_id AND dt.dag_inserted_at = at.dag_inserted_at
JOIN
v1_task t ON t.id = dt.task_id
v1_task t ON t.id = dt.task_id AND t.inserted_at = dt.task_inserted_at
JOIN
"Step" s2 ON s2."id" = t.step_id
JOIN