Fix: improve performance of cron schedule polling query (#3754)

* fix: update query to try to avoid expensive hash + nested loop

* feat: add index, gen

* fix: small bug

* chore: gen

Author: mrkaye97

cmd/hatchet-migrate/migrate/migrations/20260427190534_v1_0_102.sql

@@ -0,0 +1,11 @@
+-- +goose NO TRANSACTION
+
+-- +goose Up
+-- +goose StatementBegin
+CREATE INDEX CONCURRENTLY idx_workflow_triggers_id_version_id_tenant_id ON "WorkflowTriggers" ("id", "workflowVersionId", "tenantId");
+-- +goose StatementEnd
+
+-- +goose Down
+-- +goose StatementBegin
+DROP INDEX CONCURRENTLY idx_workflow_triggers_id_version_id_tenant_id;
+-- +goose StatementEnd

pkg/repository/sqlcv1/ticker.sql

@@ -94,17 +94,7 @@ WHERE
 RETURNING *;
 
 -- name: PollCronSchedules :many
-WITH latest_workflow_versions AS (
-    SELECT
-        "workflowId",
-        MAX("order") as max_order
-    FROM
-        "WorkflowVersion"
-    WHERE
-        "deletedAt" IS NULL
-    GROUP BY "workflowId"
-),
-eligible_cron_with_versions AS (
+WITH eligible_cron_with_versions AS MATERIALIZED (
     SELECT
         cronSchedule."parentId",
         cronSchedule."cron",
@@ -133,6 +123,17 @@ eligible_cron_with_versions AS (
         )
     FOR UPDATE OF cronSchedule SKIP LOCKED
 ),
+latest_workflow_versions AS (
+    SELECT
+        DISTINCT ON ("workflowId")
+        "workflowId",
+        "id"
+    FROM
+        "WorkflowVersion"
+    WHERE
+        "deletedAt" IS NULL
+    ORDER BY "workflowId", "order" DESC
+),
 eligible_cron_schedules AS (
     SELECT
         ecv."parentId",
@@ -143,7 +144,7 @@ eligible_cron_schedules AS (
     FROM
         eligible_cron_with_versions as ecv
     JOIN
-        latest_workflow_versions as l ON ecv."workflowId" = l."workflowId" AND ecv."order" = l.max_order
+        latest_workflow_versions as l ON ecv."workflowId" = l."workflowId" AND ecv."workflowVersionId" = l."id"
 )
 UPDATE
     "WorkflowTriggerCronRef" as cronSchedules