Function jobScheduleFilter

apps/sim/app/api/schedules/execute/route.ts:72–73

(queuedAt: Date)

  )

const jobScheduleFilter = (queuedAt: Date) =>
  and(dueFilter(queuedAt), sql`${workflowSchedule.sourceType} = 'job'`)

async function runWithDatabaseScheduleStartTurn(
  operation: () => Promise<DatabaseScheduleStartResult>