Fix: Remove dual writes into temp tables for status updates

cmd/hatchet-migrate/migrate/migrations/20260505195258_v1_0_104.sql

@@ -0,0 +1,56 @@
+-- +goose Up
+-- +goose StatementBegin
+CREATE OR REPLACE FUNCTION v1_tasks_olap_status_update_function()
+RETURNS TRIGGER AS
+$$
+BEGIN
+    UPDATE
+        v1_runs_olap r
+    SET
+        readable_status = n.readable_status
+    FROM new_rows n
+    WHERE
+        r.id = n.id
+        AND r.inserted_at = n.inserted_at
+        AND r.kind = 'TASK';
+
+    RETURN NULL;
+END;
+$$
+LANGUAGE plpgsql;
+-- +goose StatementEnd
+
+-- +goose Down
+-- +goose StatementBegin
+CREATE OR REPLACE FUNCTION v1_tasks_olap_status_update_function()
+RETURNS TRIGGER AS
+$$
+BEGIN
+    UPDATE
+        v1_runs_olap r
+    SET
+        readable_status = n.readable_status
+    FROM new_rows n
+    WHERE
+        r.id = n.id
+        AND r.inserted_at = n.inserted_at
+        AND r.kind = 'TASK';
+
+    -- insert tmp events into task status updates table if we have a dag_id
+    INSERT INTO v1_task_status_updates_tmp (
+        tenant_id,
+        dag_id,
+        dag_inserted_at
+    )
+    SELECT
+        tenant_id,
+        dag_id,
+        dag_inserted_at
+    FROM new_rows
+    WHERE dag_id IS NOT NULL;
+
+    RETURN NULL;
+END;
+$$
+LANGUAGE plpgsql;
+-- +goose StatementEnd

pkg/repository/sqlcv1/olap.sql

@@ -154,25 +154,6 @@ WHERE
     END
 ;
 
--- name: CreateTaskEventsOLAPTmp :copyfrom
-INSERT INTO v1_task_events_olap_tmp (
-    tenant_id,
-    task_id,
-    task_inserted_at,
-    event_type,
-    readable_status,
-    retry_count,
-    worker_id
-) VALUES (
-    $1,
-    $2,
-    $3,
-    $4,
-    $5,
-    $6,
-    $7
-);
-
 -- name: CreateTaskEventsOLAP :copyfrom
 INSERT INTO v1_task_events_olap (
     tenant_id,

sql/schema/v1-olap.sql

@@ -628,19 +628,6 @@ BEGIN
         AND r.inserted_at = n.inserted_at
         AND r.kind = 'TASK';
 
-    -- insert tmp events into task status updates table if we have a dag_id
-    INSERT INTO v1_task_status_updates_tmp (
-        tenant_id,
-        dag_id,
-        dag_inserted_at
-    )
-    SELECT
-        tenant_id,
-        dag_id,
-        dag_inserted_at
-    FROM new_rows
-    WHERE dag_id IS NOT NULL;
-
     RETURN NULL;
 END;
 $$