#JobProvider

#Import

1import { JobProvider } from "alepha/api/jobs";

#Overview

Coordinates cron and push jobs with a durable outbox table and a single reconciliation sweep. The actual delivery channel (queue / direct) is abstracted behind {@link JobDispatcher}, substituted by DI:

• DirectJobDispatcher (default, registered by AlephaApiJobs) — runs the handler in-process right after push() returns.
• QueueJobDispatcher (registered by AlephaApiJobsQueue) — sends the executionId through AlephaQueue so a pool of workers can pick it up.

Push flow: push() → INSERT row (pending) → dispatcher.dispatch(jobName, id) worker → claim → UPDATE running → handler → DELETE/UPDATE on success → UPDATE error / scheduled (retry) on failure

Cron flow: scheduler tick → acquire lock → executeInline (no retry) → enqueue + dispatch (retry declared)

Sweep responsibilities (every sweepCron):

• re-enqueue pending rows older than staleThreshold
• mark crashed running rows as failed and apply retry policy
• move scheduled rows with scheduledAt <= now to pending + dispatch

Trim runs on its own cron (trimCron, default hourly):

• per-job history trimmed beyond keepLastSuccess / keepLastError
• decoupled from sweep because trim cost scales with job count, not retry latency — running it every sweep is wasted work for most apps.