//#region src/types.d.ts
type JobKind = "workflow" | "agent" | "trigger" | "trigger-overview" | "workflow-canvas-annotations" | "workflow-overview" | "runtime" | "brain" | "maintenance" | "platform-agent" | "image-rollout" | "project-agent-sandbox-grace" | "project-agent-env-image" | "wake" | "sleep";
type JobTrigger = "api" | "cron" | "webhook" | "poll" | "retry" | "prompt";
/**
 * Identifies a run that dispatched this job as a child. The parent metadata
 * survives the queue boundary so the child can resume its parent at a terminal
 * outcome without treating the child as a separately-billable dispatch.
 */
type JobParent = {
  kind: "workflow" | "agent";
  runId: string;
  targetId: string;
  correlationId?: string;
};
type JobPayload = {
  kind: JobKind;
  targetId: string;
  runId: string;
  trigger: JobTrigger;
  payload: unknown;
  attempt: number;
  maxAttempts: number; /** True when this delivery is the final retry attempt. */
  exhaustedRetries?: boolean;
  scheduledAt: Date;
  jobId: string; /** Project scope for org-wide worker queues. */
  projectId?: string;
  /**
   * Deploy artifact this job must run against on an org worker.
   * Stamped at enqueue from the project's active artifact (or inherited from a parent).
   */
  artifactId?: string; /** Object-storage key for reloading {@link artifactId} after eviction. */
  artifactStorageKey?: string; /** Parent run that dispatched this child job, when applicable. */
  parent?: JobParent; /** Optional W3C trace context carrier (sibling of user payload). */
  traceContext?: Record<string, string>;
};
type EnqueueInput = {
  kind: JobKind;
  targetId: string;
  runId: string;
  trigger: JobTrigger;
  payload?: unknown;
  scheduledAt?: Date;
  attempt?: number;
  maxAttempts?: number; /** Dedupe key — pg-boss singletonKey / BullMQ jobId. */
  dedupeKey?: string; /** Project scope for org-wide worker queues. */
  projectId?: string; /** Deploy artifact this job must run against on an org worker. */
  artifactId?: string; /** Object-storage key for reloading {@link artifactId} after eviction. */
  artifactStorageKey?: string; /** Parent run that dispatched this child job, when applicable. */
  parent?: JobParent; /** Optional W3C trace context carrier (sibling of user payload). */
  traceContext?: Record<string, string>;
};
type JobHandler = (job: JobPayload) => Promise<void>;
type CancelHandler = (runId: string) => void | Promise<void>;
type StopFn = () => Promise<void> | void;
type WorkerOptions = {
  workerId?: string;
  pollIntervalMs?: number;
  leaseSweepIntervalMs?: number;
};
type JobQueue = {
  enqueue(input: EnqueueInput): Promise<string>;
  startWorker(handler: JobHandler, options?: WorkerOptions): Promise<StopFn>;
  /**
   * Temporarily lends a worker slot to a child while an agent job waits on it.
   * Backends without a hard concurrency cap may omit it.
   */
  withLentSlot?<T>(fn: () => Promise<T>): Promise<T>;
  publishCancel(runId: string): Promise<void>;
  subscribeCancel(handler: CancelHandler): Promise<StopFn>; /** Pause workers before machine suspend (BullMQ). Redis stays connected for a final next-due peek. */
  prepareForSuspend?(): Promise<void>; /** Drop Redis TCP after the final next-due check, before machine suspend (BullMQ). */
  disconnectForSuspend?(): Promise<void>; /** Reconnect Redis and resume workers after machine resume (BullMQ). */
  resumeAfterSuspend?(): Promise<void>;
  /**
   * Earliest org-queue work: `"ready"` if waiting now, a future due time, or
   * `null` when the queue is empty. Used to register one platform wake before suspend.
   */
  getNextDueAt?(): Promise<Date | "ready" | null>;
};
type CreateJobQueueOptions = {
  url?: string;
  dialect?: "postgres" | "sqlite";
  adapter?: JobQueue;
  plugin?: SchedulerPlugin;
  scope?: SchedulerScope;
  projectId?: string;
  organizationId?: string;
};
type ScheduleSyncOptions = {
  schedules: TriggerScheduleSpec[];
  scheduleOverrides?: {
    global?: string;
    byTrigger?: Record<string, string>;
  };
};
type ScheduleTickerOptions = {
  pollIntervalMs?: number;
  batchSize?: number; /** When `organization`, claims due schedules across all projects in the org schema. */
  scope?: "project" | "organization";
};
type Scheduler = JobQueue & {
  syncTriggerSchedules(options: ScheduleSyncOptions): Promise<void>;
  startScheduleTicker(options?: ScheduleTickerOptions): Promise<StopFn>;
  fireDueSchedules(asOf?: Date): Promise<number>;
  upsertTriggerSchedule?(spec: TriggerScheduleSpec, overrides?: ScheduleSyncOptions["scheduleOverrides"]): Promise<void>;
  removeTriggerSchedule?(triggerSlug: string, projectId?: string): Promise<void>;
};
type CreateSchedulerOptions = CreateJobQueueOptions;
declare const DEFAULT_RETRY_DELAY_MS = 5000;
declare function retryDelayMs(attempt: number): number;
//#endregion
//#region src/contract.d.ts
/**
 * Inlined to keep the contract database-free — structurally identical to
 * `@keystrokehq/database`'s `DatabaseDialect`. Importing it from the database
 * package would re-introduce the dependency `./contract` exists to avoid.
 */
type DatabaseDialect = "postgres" | "sqlite";
type SchedulerScope = "platform" | "project" | "organization";
type SchedulerPluginContext = {
  scope: SchedulerScope;
  url?: string;
  dialect?: DatabaseDialect;
  projectId?: string;
  organizationId?: string;
};
type TriggerScheduleSpec = {
  triggerSlug: string;
  kind: "cron" | "poll";
  schedule: string; /** IANA timezone for schedule wall-clock fields. When omitted, UTC. */
  timezone?: string; /** Project scope for org-wide worker queues. */
  projectId?: string;
};
type TriggerScheduleSyncOptions = {
  schedules: TriggerScheduleSpec[];
  scheduleOverrides?: {
    global?: string;
    byTrigger?: Record<string, string>;
  };
};
type TriggerSchedulerStartOptions = {
  pollIntervalMs?: number;
  batchSize?: number; /** When `organization`, claims due schedules across all projects in the org schema. */
  scope?: "project" | "organization";
};
type TriggerScheduler = {
  sync(options: TriggerScheduleSyncOptions): Promise<void>;
  start(options?: TriggerSchedulerStartOptions): Promise<StopFn>; /** Register or refresh one trigger schedule in the firing backend. */
  upsert?(spec: TriggerScheduleSpec, overrides?: TriggerScheduleSyncOptions["scheduleOverrides"]): Promise<void>;
  remove?(triggerSlug: string, projectId?: string): Promise<void>;
  fireDue?(asOf?: Date): Promise<number>;
};
type SchedulerPlugin = {
  name: string;
  createJobQueue(ctx: SchedulerPluginContext): Promise<JobQueue>;
  createTriggerScheduler?(ctx: SchedulerPluginContext, queue: JobQueue): Promise<TriggerScheduler>;
};
declare function defineSchedulerPlugin(plugin: SchedulerPlugin): SchedulerPlugin;
//#endregion
export { Scheduler as C, retryDelayMs as E, ScheduleTickerOptions as S, WorkerOptions as T, JobParent as _, TriggerScheduleSpec as a, JobTrigger as b, TriggerSchedulerStartOptions as c, CreateJobQueueOptions as d, CreateSchedulerOptions as f, JobKind as g, JobHandler as h, SchedulerScope as i, defineSchedulerPlugin as l, EnqueueInput as m, SchedulerPlugin as n, TriggerScheduleSyncOptions as o, DEFAULT_RETRY_DELAY_MS as p, SchedulerPluginContext as r, TriggerScheduler as s, DatabaseDialect as t, CancelHandler as u, JobPayload as v, StopFn as w, ScheduleSyncOptions as x, JobQueue as y };
//# sourceMappingURL=contract-0-808yry.d.cts.map