fix(api): update date comparison logic in getDueCronTriggers to use Unix timestamp

bchapuis · bchapuis · commit eeb3ad919f56 · 2025-06-06T20:54:15.000+02:00
diff --git a/apps/api/src/db/queries.ts b/apps/api/src/db/queries.ts
@@ -1208,7 +1208,7 @@ export async function getDueCronTriggers(
     .where(
       and(
         eq(cronTriggers.active, true),
-        sql`${cronTriggers.nextRunAt} <= ${now.getTime()}`
+        sql`${cronTriggers.nextRunAt} <= ${Math.floor(now.getTime() / 1000)}`
       )
     )
     .innerJoin(workflows, eq(workflows.id, cronTriggers.workflowId))

Original file line number	Diff line number	Diff line change
`@@ -1208,7 +1208,7 @@ export async function getDueCronTriggers(`
`1208`	`1208`	`.where(`
`1209`	`1209`	`and(`
`1210`	`1210`	`eq(cronTriggers.active, true),`
`1211`		- sql`${cronTriggers.nextRunAt} <= ${now.getTime()}`
	`1211`	+ sql`${cronTriggers.nextRunAt} <= ${Math.floor(now.getTime() / 1000)}`
`1212`	`1212`	`)`
`1213`	`1213`	`)`
`1214`	`1214`	`.innerJoin(workflows, eq(workflows.id, cronTriggers.workflowId))`