Method enqueue

apps/sim/lib/core/async-jobs/backends/database.ts:83–120

(
    type: JobType,
    payload: TPayload,
    options?: EnqueueOptions
  )

export class DatabaseJobQueue implements JobQueueBackend {
  async enqueue<TPayload>(
    type: JobType,
    payload: TPayload,
    options?: EnqueueOptions
  ): Promise<string> {
    const jobId = options?.jobId ?? `run_${generateShortId(20)}`
    const now = new Date()

    await db
      .insert(asyncJobs)
      .values({
        id: jobId,
        type,
        payload: payload as Record<string, unknown>,
        status: JOB_STATUS.PENDING,
        createdAt: now,
        runAt:
          options?.delayMs && options.delayMs > 0 ? new Date(now.getTime() + options.delayMs) : now,
        attempts: 0,
        maxAttempts: options?.maxAttempts ?? 3,
        metadata: (options?.metadata ?? {}) as Record<string, unknown>,
        updatedAt: now,
      })
      .onConflictDoNothing()

    logger.debug('Enqueued job', { jobId, type })
    if (options?.runner) {
      this.runInline(
        type,
        jobId,
        payload,
        options.runner,
        options.concurrencyKey,
        options.concurrencyLimit
      )
    }
    return jobId
  }

  async batchEnqueue<TPayload>(
    type: JobType,