@runlane/core - npm Package Compare versions

Comparing version 0.1.1 to 0.2.0

dist/index.d.cts

@@ -1,3 +0,4 @@
-import { ActorType, DeliveryMessage, DurationString, Environment, ExecuteDeliveryOptions, FailedWakeupPublish, IdempotencyKeyTTL, JsonValue, Lane, Page, PruneRunsResult, PublishedWakeup, QueueDefinition, QueueDefinition as QueueDefinition$1, QueueOptions, RetryPolicy, RunAttemptStatus, RunEvent, RunEventRecord, RunEventSortField, RunEventType, RunFailure, RunId, RunRecord, RunSortField, RunStatus, RunSummary, RunlaneIdInput, ScheduleOccurrence, Schema, SortDirection, TaskContext, TaskHandler, TaskId, TerminalRunStatus, TriggerDispatchMode, WorkerId } from "@runlane/contracts";
+import { ActorType, DeliveryMessage, DurationString, Environment, ExecuteDeliveryOptions, FailedWakeupPublish, IdempotencyKeyTTL, JsonValue, Lane, Page, PruneRunsResult, PublishedWakeup, QueueDefinition, QueueDefinition as QueueDefinition$1, QueueOptions, RetryPolicy, RunAttemptStatus, RunEvent, RunEventRecord, RunEventSortField, RunEventType, RunFailure, RunId, RunRecord, RunSortField, RunStatus, RunSummary, RunlaneIdInput, ScheduleOccurrence, Schema, SortDirection, TaskContext, TaskHandler, TaskId, TriggerDispatchMode, TriggerRunResult, WorkerId } from "@runlane/contracts";
 import * as z from "zod";
+import { Awaitable } from "@runlane/utilities";
 export * from "@runlane/contracts";
@@ -28,2 +29,20 @@
 //#endregion
+//#region src/runtime/lease-timing.d.ts
+/**
+ * Lease timing resolved before a run is claimed.
+ *
+ * Runtime execution uses this single value object for the initial lease claim and every heartbeat so the lease duration
+ * cannot drift during one task attempt.
+ */
+interface LeaseTiming {
+  /**
+   * Milliseconds to wait between durable `run.lease_heartbeat` events.
+   */
+  readonly heartbeatIntervalMs: number;
+  /**
+   * Milliseconds added to each claim or heartbeat timestamp to produce the next lease expiry.
+   */
+  readonly leaseDurationMs: number;
+}
+//#endregion
 //#region src/runtime-delivery.d.ts
@@ -230,3 +249,3 @@ /**
   limit: z.ZodOptional<z.ZodNumber>;
-  queues: z.ZodOptional<z.ZodPipe<z.ZodArray<z.ZodPipe<z.ZodObject<{
+  queues: z.ZodOptional<z.ZodReadonly<z.ZodArray<z.ZodPipe<z.ZodObject<{
     concurrencyLimit: z.ZodOptional<z.ZodNumber>;
@@ -252,13 +271,3 @@ default: z.ZodOptional<z.ZodBoolean>;
     } | undefined;
-  }>>>, z.ZodTransform<readonly {
-    concurrencyLimit: number | undefined;
-    default: boolean;
-    dispatchTimeout: `${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s` | undefined;
-    name: import("@runlane/contracts").Id<"queue">;
-  }[], {
-    concurrencyLimit: number | undefined;
-    default: boolean;
-    dispatchTimeout: `${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s` | undefined;
-    name: import("@runlane/contracts").Id<"queue">;
-  }[]>>>;
+  }>>>>>;
   runAt: z.ZodOptional<z.ZodObject<{
@@ -272,4 +281,4 @@ from: z.ZodOptional<z.ZodDate>;
   sourceRunId: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<import("@runlane/contracts").Id<"run">, string>>>;
-  statuses: z.ZodOptional<z.ZodPipe<z.ZodArray<z.ZodEnum<typeof RunStatus>>, z.ZodTransform<readonly RunStatus[], RunStatus[]>>>;
-  taskIds: z.ZodOptional<z.ZodPipe<z.ZodArray<z.ZodPipe<z.ZodString, z.ZodTransform<import("@runlane/contracts").Id<"task">, string>>>, z.ZodTransform<readonly TaskId[], import("@runlane/contracts").Id<"task">[]>>>;
+  statuses: z.ZodOptional<z.ZodReadonly<z.ZodArray<z.ZodEnum<typeof RunStatus>>>>;
+  taskIds: z.ZodOptional<z.ZodReadonly<z.ZodArray<z.ZodPipe<z.ZodString, z.ZodTransform<import("@runlane/contracts").Id<"task">, string>>>>>;
   updatedAt: z.ZodOptional<z.ZodObject<{
@@ -283,3 +292,3 @@ from: z.ZodOptional<z.ZodDate>;
  */
-type ListRunsOptions = z.infer<typeof listRunsOptionsValidator>;
+type ListRunsOptions = z.input<typeof listRunsOptionsValidator>;
 declare const findActiveRunOptionsValidator: z.ZodObject<{
@@ -311,3 +320,3 @@ idempotencyKey: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<import("@runlane/contracts").Id<"idempotency_key">, string>>>;
   sortDirection: z.ZodOptional<z.ZodEnum<typeof SortDirection>>;
-  types: z.ZodOptional<z.ZodPipe<z.ZodArray<z.ZodEnum<typeof RunEventType>>, z.ZodTransform<readonly RunEventType[], RunEventType[]>>>;
+  types: z.ZodOptional<z.ZodReadonly<z.ZodArray<z.ZodEnum<typeof RunEventType>>>>;
 }, z.core.$strict>;
@@ -317,3 +326,3 @@ /**
  */
-type ListRunEventsOptions = z.infer<typeof listRunEventsOptionsValidator>;
+type ListRunEventsOptions = z.input<typeof listRunEventsOptionsValidator>;
 declare const cancelRunOptionsValidator: z.ZodObject<{
@@ -331,3 +340,3 @@ actor: z.ZodOptional<z.ZodObject<{
  */
-type CancelRunOptions = z.infer<typeof cancelRunOptionsValidator>;
+type CancelRunOptions = z.input<typeof cancelRunOptionsValidator>;
 declare const createLinkedRunOptionsValidator: z.ZodObject<{
@@ -367,3 +376,3 @@ actor: z.ZodOptional<z.ZodObject<{
  */
-type CreateLinkedRunOptions = z.infer<typeof createLinkedRunOptionsValidator>;
+type CreateLinkedRunOptions = z.input<typeof createLinkedRunOptionsValidator>;
 declare const pruneRunsOptionsValidator: z.ZodObject<{
@@ -383,3 +392,3 @@ actor: z.ZodOptional<z.ZodObject<{
   }>>]>;
-  statuses: z.ZodOptional<z.ZodPipe<z.ZodArray<z.ZodPipe<z.ZodEnum<typeof RunStatus>, z.ZodTransform<RunStatus.Cancelled | RunStatus.Failed | RunStatus.Succeeded, RunStatus>>>, z.ZodTransform<readonly TerminalRunStatus[], (RunStatus.Cancelled | RunStatus.Failed | RunStatus.Succeeded)[]>>>;
+  statuses: z.ZodOptional<z.ZodReadonly<z.ZodArray<z.ZodPipe<z.ZodEnum<typeof RunStatus>, z.ZodTransform<RunStatus.Cancelled | RunStatus.Failed | RunStatus.Succeeded, RunStatus>>>>>;
 }, z.core.$strict>;
@@ -389,3 +398,3 @@ /**
  */
-type PruneRunsOptions = z.infer<typeof pruneRunsOptionsValidator>;
+type PruneRunsOptions = z.input<typeof pruneRunsOptionsValidator>;
 //#endregion
@@ -438,2 +447,6 @@ //#region src/runtime/operator-api.d.ts
   readonly concurrency?: number;
+  /**
+   * Called after a worker slot executes one run attempt and persists its final state.
+   */
+  readonly onRunExecuted?: (run: RunRecord) => Awaitable<void>;
 }
@@ -476,3 +489,3 @@ /**
 //#region src/runtime.d.ts
-declare const triggerOptionsValidator: z.ZodObject<{
+declare const runCreationOptionsValidator: z.ZodObject<{
   actor: z.ZodOptional<z.ZodObject<{
@@ -512,18 +525,115 @@ id: z.ZodOptional<z.ZodString>;
 }, z.core.$strict>;
-declare const executeNextInputValidator: z.ZodObject<{
-  heartbeatInterval: z.ZodOptional<z.ZodPipe<z.ZodPipe<z.ZodString, z.ZodTransform<{
+declare const runNowOptionsValidator: z.ZodPipe<z.ZodObject<{
+  actor: z.ZodOptional<z.ZodObject<{
+    id: z.ZodOptional<z.ZodString>;
+    type: z.ZodEnum<typeof ActorType>;
+  }, z.core.$strict>>;
+  concurrencyKey: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<import("@runlane/contracts").Id<"concurrency_key">, string>>>;
+  idempotencyKey: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<import("@runlane/contracts").Id<"idempotency_key">, string>>>;
+  idempotencyKeyTTL: z.ZodOptional<z.ZodType<import("@runlane/contracts").IdempotencyKeyTTL, unknown, z.core.$ZodTypeInternals<import("@runlane/contracts").IdempotencyKeyTTL, unknown>>>;
+  meta: z.ZodOptional<z.ZodType<import("@runlane/contracts").JsonObject, unknown, z.core.$ZodTypeInternals<import("@runlane/contracts").JsonObject, unknown>>>;
+  queue: z.ZodOptional<z.ZodPipe<z.ZodObject<{
+    concurrencyLimit: z.ZodOptional<z.ZodNumber>;
+    default: z.ZodOptional<z.ZodBoolean>;
+    dispatchTimeout: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<{
+      duration: import("@runlane/utilities").DurationString;
+      milliseconds: number;
+    }, string>>>;
+    name: z.ZodString;
+  }, z.core.$strict>, z.ZodTransform<{
+    concurrencyLimit: number | undefined;
+    default: boolean;
+    dispatchTimeout: `${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s` | undefined;
+    name: import("@runlane/contracts").Id<"queue">;
+  }, {
+    name: string;
+    concurrencyLimit?: number | undefined;
+    default?: boolean | undefined;
+    dispatchTimeout?: {
+      duration: import("@runlane/utilities").DurationString;
+      milliseconds: number;
+    } | undefined;
+  }>>>;
+  runId: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<import("@runlane/contracts").Id<"run">, string>>>;
+  singletonKey: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<import("@runlane/contracts").Id<"singleton_key">, string>>>;
+  traceCarrier: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodString>>;
+  heartbeatInterval: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<{
     duration: import("@runlane/utilities").DurationString;
     milliseconds: number;
-  }, string>>, z.ZodTransform<`${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s`, {
+  }, string>>>;
+  leaseDuration: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<{
     duration: import("@runlane/utilities").DurationString;
     milliseconds: number;
-  }>>>;
-  leaseDuration: z.ZodOptional<z.ZodPipe<z.ZodPipe<z.ZodString, z.ZodTransform<{
+  }, string>>>;
+  signal: z.ZodOptional<z.ZodType<AbortSignal, AbortSignal, z.core.$ZodTypeInternals<AbortSignal, AbortSignal>>>;
+  workerId: z.ZodOptional<z.ZodType<WorkerId, string, z.core.$ZodTypeInternals<WorkerId, string>>>;
+}, z.core.$strict>, z.ZodTransform<{
+  actor?: {
+    type: ActorType;
+    id?: string | undefined;
+  } | undefined;
+  concurrencyKey?: import("@runlane/contracts").Id<"concurrency_key"> | undefined;
+  idempotencyKey?: import("@runlane/contracts").Id<"idempotency_key"> | undefined;
+  idempotencyKeyTTL?: import("@runlane/contracts").IdempotencyKeyTTL | undefined;
+  meta?: import("@runlane/contracts").JsonObject | undefined;
+  queue?: {
+    concurrencyLimit: number | undefined;
+    default: boolean;
+    dispatchTimeout: `${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s` | undefined;
+    name: import("@runlane/contracts").Id<"queue">;
+  } | undefined;
+  runId?: import("@runlane/contracts").Id<"run"> | undefined;
+  singletonKey?: import("@runlane/contracts").Id<"singleton_key"> | undefined;
+  traceCarrier?: Record<string, string> | undefined;
+  heartbeatInterval?: {
     duration: import("@runlane/utilities").DurationString;
     milliseconds: number;
-  }, string>>, z.ZodTransform<`${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s`, {
+  } | undefined;
+  leaseDuration?: {
     duration: import("@runlane/utilities").DurationString;
     milliseconds: number;
-  }>>>;
-  queues: z.ZodOptional<z.ZodArray<z.ZodPipe<z.ZodObject<{
+  } | undefined;
+  signal?: AbortSignal | undefined;
+  workerId?: WorkerId | undefined;
+} & {
+  leaseTiming: LeaseTiming;
+}, {
+  actor?: {
+    type: ActorType;
+    id?: string | undefined;
+  } | undefined;
+  concurrencyKey?: import("@runlane/contracts").Id<"concurrency_key"> | undefined;
+  idempotencyKey?: import("@runlane/contracts").Id<"idempotency_key"> | undefined;
+  idempotencyKeyTTL?: import("@runlane/contracts").IdempotencyKeyTTL | undefined;
+  meta?: import("@runlane/contracts").JsonObject | undefined;
+  queue?: {
+    concurrencyLimit: number | undefined;
+    default: boolean;
+    dispatchTimeout: `${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s` | undefined;
+    name: import("@runlane/contracts").Id<"queue">;
+  } | undefined;
+  runId?: import("@runlane/contracts").Id<"run"> | undefined;
+  singletonKey?: import("@runlane/contracts").Id<"singleton_key"> | undefined;
+  traceCarrier?: Record<string, string> | undefined;
+  heartbeatInterval?: {
+    duration: import("@runlane/utilities").DurationString;
+    milliseconds: number;
+  } | undefined;
+  leaseDuration?: {
+    duration: import("@runlane/utilities").DurationString;
+    milliseconds: number;
+  } | undefined;
+  signal?: AbortSignal | undefined;
+  workerId?: WorkerId | undefined;
+}>>;
+declare const executeNextInputValidator: z.ZodPipe<z.ZodObject<{
+  heartbeatInterval: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<{
+    duration: import("@runlane/utilities").DurationString;
+    milliseconds: number;
+  }, string>>>;
+  leaseDuration: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<{
+    duration: import("@runlane/utilities").DurationString;
+    milliseconds: number;
+  }, string>>>;
+  queues: z.ZodOptional<z.ZodReadonly<z.ZodArray<z.ZodPipe<z.ZodObject<{
     concurrencyLimit: z.ZodOptional<z.ZodNumber>;
@@ -549,6 +659,42 @@ default: z.ZodOptional<z.ZodBoolean>;
     } | undefined;
-  }>>>>;
-  signal: z.ZodOptional<z.ZodType<AbortSignal, unknown, z.core.$ZodTypeInternals<AbortSignal, unknown>>>;
+  }>>>>>;
+  signal: z.ZodOptional<z.ZodType<AbortSignal, AbortSignal, z.core.$ZodTypeInternals<AbortSignal, AbortSignal>>>;
   workerId: z.ZodOptional<z.ZodType<WorkerId, string, z.core.$ZodTypeInternals<WorkerId, string>>>;
-}, z.core.$strict>;
+}, z.core.$strict>, z.ZodTransform<{
+  heartbeatInterval?: {
+    duration: import("@runlane/utilities").DurationString;
+    milliseconds: number;
+  } | undefined;
+  leaseDuration?: {
+    duration: import("@runlane/utilities").DurationString;
+    milliseconds: number;
+  } | undefined;
+  queues?: readonly {
+    concurrencyLimit: number | undefined;
+    default: boolean;
+    dispatchTimeout: `${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s` | undefined;
+    name: import("@runlane/contracts").Id<"queue">;
+  }[] | undefined;
+  signal?: AbortSignal | undefined;
+  workerId?: WorkerId | undefined;
+} & {
+  leaseTiming: LeaseTiming;
+}, {
+  heartbeatInterval?: {
+    duration: import("@runlane/utilities").DurationString;
+    milliseconds: number;
+  } | undefined;
+  leaseDuration?: {
+    duration: import("@runlane/utilities").DurationString;
+    milliseconds: number;
+  } | undefined;
+  queues?: readonly {
+    concurrencyLimit: number | undefined;
+    default: boolean;
+    dispatchTimeout: `${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s` | undefined;
+    name: import("@runlane/contracts").Id<"queue">;
+  }[] | undefined;
+  signal?: AbortSignal | undefined;
+  workerId?: WorkerId | undefined;
+}>>;
 type TaskCatalogInput = Readonly<Record<string, TaskRegistrationInput>>;
@@ -558,3 +704,3 @@ type TaskCollectionInput = readonly TaskRegistrationInput[] | TaskCatalogInput;
   clock: z.ZodOptional<z.ZodObject<{
-    now: z.ZodType<() => Date, unknown, z.core.$ZodTypeInternals<() => Date, unknown>>;
+    now: z.ZodType<() => Date, () => Date, z.core.$ZodTypeInternals<() => Date, () => Date>>;
   }, z.core.$strip>>;
@@ -580,2 +726,3 @@ dispatch: z.ZodOptional<z.ZodObject<{
         persistsOutbox: boolean;
+        processLocalState: boolean;
         prunesRuns: boolean;
@@ -601,2 +748,3 @@ readsRunHistory: boolean;
         persistsOutbox: boolean;
+        processLocalState: boolean;
         prunesRuns: boolean;
@@ -663,2 +811,3 @@ readsRunHistory: boolean;
         persistsOutbox: boolean;
+        processLocalState: boolean;
         prunesRuns: boolean;
@@ -684,2 +833,3 @@ readsRunHistory: boolean;
         persistsOutbox: boolean;
+        processLocalState: boolean;
         prunesRuns: boolean;
@@ -746,2 +896,3 @@ readsRunHistory: boolean;
         persistsOutbox: boolean;
+        processLocalState: boolean;
         prunesRuns: boolean;
@@ -767,2 +918,3 @@ readsRunHistory: boolean;
         persistsOutbox: boolean;
+        processLocalState: boolean;
         prunesRuns: boolean;
@@ -829,2 +981,3 @@ readsRunHistory: boolean;
         persistsOutbox: boolean;
+        processLocalState: boolean;
         prunesRuns: boolean;
@@ -850,2 +1003,3 @@ readsRunHistory: boolean;
         persistsOutbox: boolean;
+        processLocalState: boolean;
         prunesRuns: boolean;
@@ -932,8 +1086,13 @@ readsRunHistory: boolean;
  */
-type TriggerRunOptions = z.input<typeof triggerOptionsValidator>;
+type TriggerRunOptions = z.input<typeof runCreationOptionsValidator>;
 /**
+ * Options for durably creating and executing one run in the current process.
+ */
+type RunNowOptions = z.input<typeof runNowOptionsValidator>;
+/**
  * Options for executing one due run.
  */
-type ExecuteNextRunOptions = z.output<typeof executeNextInputValidator>;
+type ExecuteNextRunOptions = z.input<typeof executeNextInputValidator>;
 type TriggerRunArgs<TInput extends JsonValue | undefined> = undefined extends TInput ? [payload?: TInput, options?: TriggerRunOptions] : [payload: TInput, options?: TriggerRunOptions];
+type RunNowArgs<TInput extends JsonValue | undefined> = undefined extends TInput ? [payload?: TInput, options?: RunNowOptions] : [payload: TInput, options?: RunNowOptions];
 type RuntimeTasksFromOptions<TOptions> = TOptions extends {
@@ -985,4 +1144,8 @@ readonly tasks: infer TTasks;
    */
-  trigger<TPayload extends JsonValue | undefined, TInput extends JsonValue | undefined>(taskDefinition: Task<TPayload, TInput>, ...args: TriggerRunArgs<TInput>): Promise<RunRecord>;
+  trigger<TPayload extends JsonValue | undefined, TInput extends JsonValue | undefined>(taskDefinition: Task<TPayload, TInput>, ...args: TriggerRunArgs<TInput>): Promise<TriggerRunResult>;
   /**
+   * Validates payload input, creates one durable run with an owned lease, and executes exactly one attempt immediately.
+   */
+  runNow<TPayload extends JsonValue | undefined, TInput extends JsonValue | undefined>(taskDefinition: Task<TPayload, TInput>, ...args: RunNowArgs<TInput>): Promise<RunRecord>;
+  /**
    * Runs one maintenance pass over registered schedules, due waiting runs, expired leases, and pending outbox rows.
@@ -1029,3 +1192,3 @@ */
 //#endregion
-export { type CancelRunOptions, type CreateLinkedRunOptions, type CreateRunlaneOptions, type CronTaskScheduleOptions, type DispatchPolicyOptions, type DrainWorkerOptions, ExecuteDeliveryIgnoredReason, type ExecuteDeliveryResult, ExecuteDeliveryStatus, type ExecuteNextRunOptions, type IntervalTaskScheduleOptions, type ListRunEventsOptions, type ListRunsOptions, type OnceTaskScheduleOptions, type OutboxFlushResult, type PollWorkerOptions, type ProjectRunEventsCommand, type PruneRunsOptions, type QueueDefinition, type QueueOptions, type ResetIdempotencyKeyOptions, type RunAttemptSummary, type RunlaneIdempotencyKeysApi, type RunlaneRunsApi, type RunlaneRuntime, type RunlaneWorker, type ScheduleMaterialization, type Task, type TaskContext, type TaskHandler, type TaskOptions, type TaskRegistrationInput, type TaskScheduleInput, type TaskScheduleOptions, type TaskScheduleOptionsBase, type TickOptions, type TickResult, type TriggerDispatchModeInput, type TriggerRunOptions, WorkerMode, type WorkerOptions, createRunlane, projectRunEvents, queue, task };
+export { type CancelRunOptions, type CreateLinkedRunOptions, type CreateRunlaneOptions, type CronTaskScheduleOptions, type DispatchPolicyOptions, type DrainWorkerOptions, ExecuteDeliveryIgnoredReason, type ExecuteDeliveryResult, ExecuteDeliveryStatus, type ExecuteNextRunOptions, type IntervalTaskScheduleOptions, type ListRunEventsOptions, type ListRunsOptions, type OnceTaskScheduleOptions, type OutboxFlushResult, type PollWorkerOptions, type ProjectRunEventsCommand, type PruneRunsOptions, type QueueDefinition, type QueueOptions, type ResetIdempotencyKeyOptions, type RunAttemptSummary, type RunNowOptions, type RunlaneIdempotencyKeysApi, type RunlaneRunsApi, type RunlaneRuntime, type RunlaneWorker, type ScheduleMaterialization, type Task, type TaskContext, type TaskHandler, type TaskOptions, type TaskRegistrationInput, type TaskScheduleInput, type TaskScheduleOptions, type TaskScheduleOptionsBase, type TickOptions, type TickResult, type TriggerDispatchModeInput, type TriggerRunOptions, WorkerMode, type WorkerOptions, createRunlane, projectRunEvents, queue, task };
 //# sourceMappingURL=index.d.cts.map

dist/index.d.cts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.d.cts","names":[],"sources":["../src/queue.ts","../src/run-projection.ts","../src/runtime-delivery.ts","../src/schedule/types.ts","../src/task.ts","../src/runtime/idempotency-key-api.ts","../src/runtime/schedule-materialization.ts","../src/runtime/maintenance.ts","../src/runtime/operator-validation.ts","../src/runtime/operator-api.ts","../src/worker.ts","../src/runtime.ts","../src/runtime/dispatch-policy.ts"],"mappings":";;;;;;;;iBAYgB,KAAA,CAAM,OAAA,EAAS,YAAA,GAAe,eAAe;;;;;;;;AAA7D;UCaiB,uBAAA;EAAA,SACN,UAAA,GAAa,SAAA;EAAA,SACb,gBAAA;EAAA,SACA,MAAA,WAAiB,QAAQ;AAAA;;;ADhByB;iBCsB7C,gBAAA,CAAiB,OAAA,EAAS,uBAAA,GAA0B,SAAS;;;;;;aCpBjE,4BAAA;EACV,SAAA;EACA,aAAA;EACA,SAAA;EACA,MAAA;EACA,WAAA;EACA,QAAA;EACA,UAAA;AAAA;;AFT2D;;aEejD,qBAAA;EACV,QAAA;EACA,OAAO;AAAA;;;;KAMG,qBAAA;EAAA,SAEG,GAAA,EAAK,SAAA;EAAA,SACL,MAAA,EAAQ,qBAAA,CAAsB,QAAA;AAAA;EAAA,SAG9B,MAAA,EAAQ,4BAAA;EDba;AAMpC;;;EANoC,SCkBrB,GAAA,GAAM,SAAA;EAAA,SACN,MAAA,EAAQ,qBAAA,CAAsB,OAAA;AAAA;;;KCtCxC,qBAAA,gBAAqC,SAAA,kCAA2C,MAAA;EAAA,SACtE,OAAA,GAAU,MAAA;AAAA;EAAA,SACV,OAAA,EAAS,MAAA;AAAA;AHCxB;;;AAAA,UGIiB,uBAAA;EAAA,SACN,EAAA,EAAI,cAAA;EAAA,SACJ,KAAA,GAAQ,iBAAe;EAAA,SACvB,OAAA;AAAA;AHPkD;;;AAAA,KGajD,uBAAA,gBAAuC,SAAA,eAAwB,SAAA,gBACzE,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,KAAA,EAAO,IAAA;AAAA;;;;KAMV,2BAAA,gBAA2C,SAAA,eAAwB,SAAA,gBAC7E,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,KAAA,EAAO,cAAA;EAAA,SACP,QAAA,GAAW,IAAA;EAAA,SACX,MAAA,GAAS,IAAA;AAAA;AFXY;AAMpC;;AANoC,KEiBxB,uBAAA,gBAAuC,SAAA,eAAwB,SAAA,gBACzE,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,IAAA;EAAA,SACA,QAAA;AAAA;;;AFf8D;KEqBjE,mBAAA,gBAAmC,SAAA,eAAwB,SAAA,gBACnE,uBAAA,CAAwB,MAAA,IACxB,2BAAA,CAA4B,MAAA,IAC5B,uBAAA,CAAwB,MAAA;;;AD5C5B;KCiDY,iBAAA,gBAAiC,SAAA,eAAwB,SAAA,gBACjE,mBAAA,CAAoB,MAAA,aACX,mBAAA,CAAoB,MAAA;;;KCrC5B,sBAAA,kBAAwC,SAAA,iBAA0B,OAAA,EAAS,QAAQ;;;AJhBxF;;;UIuBiB,WAAA,kBACE,SAAA,eAAwB,SAAA,6BAC1B,SAAA,eAAwB,QAAA;EAAA,SAM9B,EAAA,EAAI,cAAA,CAAe,OAAA;EAAA,SACnB,MAAA,EAAQ,MAAA,CAAO,MAAA,EAAQ,QAAA;EAAA,SACvB,GAAA,EAAK,WAAA,CAAY,QAAA;EAAA,SACjB,KAAA,GAAQ,iBAAA;EAAA,SACR,KAAA,GAAQ,WAAA;EAAA,SACR,QAAA,GAAW,iBAAA,CAAkB,MAAA;EAAA,SAC7B,YAAA,GAAe,cAAA,CAAe,aAAA,IAAiB,sBAAA,CAAuB,QAAA;EAAA,SACtE,cAAA,GAAiB,cAAA,CAAe,eAAA,IAAmB,sBAAA,CAAuB,QAAA;EAAA,SAC1E,iBAAA,GAAoB,iBAAA;EAAA,SACpB,cAAA,GAAiB,cAAA,CAAe,eAAA,IAAmB,sBAAA,CAAuB,QAAA;AAAA;;;;UAMpE,IAAA,kBACE,SAAA,eAAwB,SAAA,6BAC1B,SAAA,eAAwB,QAAA,UAC/B,IAAA,CAAK,WAAA,CAAY,QAAA,EAAU,MAAA;EAAA,SAC1B,EAAA,EAAI,MAAA;EAAA,SACJ,KAAA,GAAQ,iBAAA;AAAA;AHnCiB;AAMpC;;;;;;AANoC,UG6CnB,qBAAA;EAAA,SACN,EAAA,EAAI,cAAA;EAAA,SACJ,MAAA,EAAQ,MAAA,UAAgB,SAAA;EAAA,SACxB,GAAA,GAAM,OAAA,SAAgB,OAAA,EAAS,WAAA,KAAgB,UAAA,CAAW,WAAA,CAAY,SAAA;EAAA,SACtE,KAAA,GAAQ,iBAAA;EAAA,SACR,KAAA,GAAQ,WAAA;EAAA,SACR,QAAA,GAAW,iBAAA;EAAA,SACX,YAAA,GAAe,cAAA,GAAiB,sBAAA;EAAA,SAChC,cAAA,GAAiB,cAAA,GAAiB,sBAAA;EAAA,SAClC,iBAAA,GAAoB,iBAAA;EAAA,SACpB,cAAA,GAAiB,cAAA,GAAiB,sBAAA;AAAA;;;;iBAgH7B,IAAA,kBACG,SAAA,6BACF,SAAA,eAAwB,QAAA,mLAAA,CAMvC,UAAA,EAAY,WAAA,CAAY,QAAA,EAAU,MAAA,EAAQ,OAAA,EAAS,aAAA,EAAe,eAAA,EAAiB,eAAA,IAClF,IAAA,CAAK,QAAA,EAAU,MAAA;;;cC5LZ,mCAAA,EAAmC,CAAA,CAAA,SAAA;;;;;;KAO7B,0BAAA,GAA6B,CAAA,CAAE,KAAK,QAAQ,mCAAA;;;;UAKvC,yBAAA;EACf,KAAA,kBAAuB,SAAA,6BAAsC,SAAA,cAC3D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,GAC/B,OAAA,EAAS,0BAAA,GACR,OAAA;AAAA;;;;ALpBwD;;UMuC5C,uBAAA;EAAA,SACN,UAAA,EAAY,kBAAA;EAAA,SACZ,GAAA,EAAK,SAAS;AAAA;;;;UAMR,0BAAA;EAAA,SACN,YAAA,WAAuB,uBAAuB;AAAA;;;;ANhDzD;;UO2BiB,iBAAA;EAAA,SACN,YAAA,WAAuB,mBAAA;EAAA,SACvB,MAAA,WAAiB,mBAAA;EAAA,SACjB,SAAA,WAAoB,eAAA;AAAA;;AP9B8B;;UOoC5C,UAAA;EAAA,SACN,sBAAA,WAAiC,SAAA;EAAA,SACjC,iBAAA,WAA4B,SAAA;EAAA,SAC5B,YAAA,EAAc,0BAAA;EAAA,SACd,MAAA,EAAQ,iBAAA;AAAA;;;;KAMP,WAAA,GAAc,CAAA,CAAE,KAAK,QAAQ,oBAAA;;;AN9BL;cMsCvB,oBAAA,EAAoB,CAAA,CAAA,SAAA;;;;;;;;cCgBpB,wBAAA,EAAwB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KA4BzB,eAAA,GAAkB,CAAA,CAAE,KAAK,QAAQ,wBAAA;AAAA,cAEhC,6BAAA,EAA6B,CAAA,CAAA,SAAA;;;;;;;;KAkB9B,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,6BAAA;AAAA,cAErC,8BAAA,EAA8B,CAAA,CAAA,SAAA;;;;;;ANrFS;KM6FxC,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,8BAAA;AAAA,cAEtC,6BAAA,EAA6B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;KAe9B,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,6BAAA;AAAA,cAarC,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;;KAO1B,gBAAA,GAAmB,CAAA,CAAE,KAAK,QAAQ,yBAAA;AAAA,cAEjC,+BAAA,EAA+B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAQhC,sBAAA,GAAyB,CAAA,CAAE,KAAK,QAAQ,+BAAA;AAAA,cAavC,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;KAe1B,gBAAA,GAAmB,CAAA,CAAE,KAAK,QAAQ,yBAAA;;;;;;UCjJ7B,cAAA;EACf,QAAA,CAAS,KAAA,EAAO,KAAA,GAAQ,OAAA,UAAiB,iBAAA;EACzC,MAAA,CAAO,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,gBAAA,GAAmB,OAAA,CAAQ,SAAA;EAC1D,MAAA,CAAO,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,oBAAA,GAAuB,OAAA,CAAQ,IAAA,CAAK,cAAA;EACnE,UAAA,CAAW,OAAA,EAAS,oBAAA,GAAuB,OAAA,CAAQ,SAAA;EACnD,WAAA,CAAY,OAAA,EAAS,qBAAA,GAAwB,OAAA,CAAQ,SAAA;EACrD,GAAA,CAAI,KAAA,EAAO,KAAA,GAAQ,OAAA,CAAQ,SAAA;EAC3B,IAAA,CAAK,OAAA,GAAU,eAAA,GAAkB,OAAA,CAAQ,IAAA,CAAK,UAAA;EAC9C,KAAA,CAAM,OAAA,EAAS,gBAAA,GAAmB,OAAA,CAAQ,eAAA;EAC1C,KAAA,CAAM,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,SAAA;EAC/D,KAAA,CAAM,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,SAAA;AAAA;AAAA,UAahD,iBAAA;EAAA,SACN,OAAA;EAAA,SACA,WAAA,GAAc,IAAA;EAAA,SACd,OAAA,GAAU,UAAA;EAAA,SACV,OAAA;IAAA,SACE,KAAA;IAAA,SACA,MAAA;IAAA,SACA,QAAA,EAAU,IAAA;EAAA;EAAA,SAEZ,KAAA;IAAA,SACE,KAAA;IAAA,SACA,OAAA,EAAS,IAAA;EAAA;EAAA,SAEX,SAAA,EAAW,IAAA;EAAA,SACX,MAAA,EAAQ,gBAAA;AAAA;;;;;;aC5EP,UAAA;EACV,KAAA;EACA,IAAI;AAAA;;;;UAmBI,iBAAA,SAA0B,qBAAqB;EAAA,SAC9C,WAAW;AAAA;ATzBc;AAMpC;;;;;AANoC,USkCnB,iBAAA,SAA0B,iBAAA;EAAA,SAChC,cAAA,GAAiB,cAAA;EAAA,SACjB,IAAA,GAAO,UAAA,CAAW,IAAA;AAAA;;;;ARlD7B;;;UQ2DiB,kBAAA,SAA2B,iBAAiB;EAAA,SAClD,OAAA;EAAA,SACA,IAAA,EAAM,UAAA,CAAW,KAAA;AAAA;;;;KAMhB,aAAA,GAAgB,kBAAA,GAAqB,iBAAiB;;AR5DtD;AAMZ;UQ2DiB,aAAA;EAAA,SACN,MAAA,EAAQ,OAAA;EAAA,SACR,IAAA,EAAM,UAAA;EAAA,SACN,MAAA,YAAkB,iBAAA;EAAA,SAClB,QAAA,EAAU,QAAA;EACnB,IAAA,IAAQ,OAAA;AAAA;;;cCkDJ,uBAAA,EAAuB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;cA0BvB,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAoB1B,gBAAA,GAAmB,QAAA,CAAS,MAAA,SAAe,qBAAA;AAAA,KAC3C,mBAAA,YAA+B,qBAAA,KAA0B,gBAAgB;AAAA,cAYxE,0BAAA,EAA0B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAkCpB,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,0BAAA;;;;KAKtC,iBAAA,GAAoB,CAAA,CAAE,KAAK,QAAQ,uBAAA;;;;KAKnC,qBAAA,GAAwB,CAAA,CAAE,MAAM,QAAQ,yBAAA;AAAA,KAO/C,cAAA,gBAA8B,SAAA,kCAA2C,MAAA,IACzE,OAAA,GAAU,MAAA,EAAQ,OAAA,GAAU,iBAAA,KAC5B,OAAA,EAAS,MAAA,EAAQ,OAAA,GAAU,iBAAA;AAAA,KAE3B,uBAAA,aAAoC,QAAA;EAAA,SAA4B,KAAA;AAAA,IACjE,MAAA,GACA,QAAA;EAAA,SAA4B,KAAA;AAAA,IAC1B,MAAA;;;AN3ON;UMiPiB,cAAA,UAAwB,mBAAA;;;;WAI9B,WAAA,EAAa,WAAA;ENrPgC;;AAAmC;EAAnC,SMyP7C,eAAA,EAAiB,yBAAA;ENpPc;;;EAAA,SMwP/B,IAAA,EAAM,IAAA;ENtPQ;;;EAAA,SM0Pd,MAAA,WAAiB,iBAAA;ENxPvB;;;EAAA,SM4PM,IAAA,EAAM,cAAA;EN/PT;;;;;EAAA,SMqQG,KAAA,EAAO,MAAA;ENpQiB;;;EMwQjC,KAAA,IAAS,OAAA;ENtQN;;AAAO;EM0QV,KAAA,IAAS,OAAA;;;ALvPX;EK2PE,OAAA,kBAAyB,SAAA,6BAAsC,SAAA,cAC7D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,MAC5B,IAAA,EAAM,cAAA,CAAe,MAAA,IACvB,OAAA,CAAQ,SAAA;;;;EAIX,IAAA,CAAK,OAAA,GAAU,WAAA,GAAc,OAAA,CAAQ,UAAA;ELhQ5B;;;EKoQT,eAAA,CAAgB,OAAA,EAAS,eAAA,EAAiB,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,qBAAA;EL9PtE;;;EKkQf,WAAA,CAAY,OAAA,GAAU,qBAAA,GAAwB,OAAA,CAAQ,SAAA;ELjQC;;;EKqQvD,MAAA,CAAO,OAAA,GAAU,aAAA,GAAgB,aAAA;AAAA;;;;;;iBA6MnB,aAAA,wBAAqC,oBAAA,CAAA,CACnD,OAAA,EAAS,QAAA,GACR,cAAA,CAAe,uBAAA,CAAwB,QAAA;AAAA,iBAC1B,aAAA,CAAc,OAAA,EAAS,oBAAA,GAAuB,cAAc;;;cC1gBtE,iCAAA,EAAiC,CAAA,CAAA,OAAA,QAAA,mBAAA;;;AZKvC;cYAa,uBAAA,EAAuB,CAAA,CAAA,SAAA;;;;;;KAOxB,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,uBAAA;AZPU;;;AAAA,KYYjD,wBAAA,GAA2B,CAAA,CAAE,KAAK,QAAQ,iCAAA"}
+{"version":3,"file":"index.d.cts","names":[],"sources":["../src/queue.ts","../src/run-projection.ts","../src/runtime/lease-timing.ts","../src/runtime-delivery.ts","../src/schedule/types.ts","../src/task.ts","../src/runtime/idempotency-key-api.ts","../src/runtime/schedule-materialization.ts","../src/runtime/maintenance.ts","../src/runtime/operator-validation.ts","../src/runtime/operator-api.ts","../src/worker.ts","../src/runtime.ts","../src/runtime/dispatch-policy.ts"],"mappings":";;;;;;;;;iBAYgB,KAAA,CAAM,OAAA,EAAS,YAAA,GAAe,eAAe;;;;;;;;;UCa5C,uBAAA;EAAA,SACN,UAAA,GAAa,SAAA;EAAA,SACb,gBAAA;EAAA,SACA,MAAA,WAAiB,QAAQ;AAAA;;;;iBAMpB,gBAAA,CAAiB,OAAA,EAAS,uBAAA,GAA0B,SAAS;;;;;;;;ADtB7E;UEHiB,WAAA;;;;WAIN,mBAAA;EFDmC;;AAAe;EAAf,SEKnC,eAAe;AAAA;;;;;;aCHd,4BAAA;EACV,SAAA;EACA,aAAA;EACA,SAAA;EACA,MAAA;EACA,WAAA;EACA,QAAA;EACA,UAAA;AAAA;;;AHT2D;aGejD,qBAAA;EACV,QAAA;EACA,OAAO;AAAA;;;;KAMG,qBAAA;EAAA,SAEG,GAAA,EAAK,SAAA;EAAA,SACL,MAAA,EAAQ,qBAAA,CAAsB,QAAA;AAAA;EAAA,SAG9B,MAAA,EAAQ,4BAAA;EFba;AAAA;AAMpC;;EANoC,SEkBrB,GAAA,GAAM,SAAA;EAAA,SACN,MAAA,EAAQ,qBAAA,CAAsB,OAAA;AAAA;;;KCtCxC,qBAAA,gBAAqC,SAAA,kCAA2C,MAAA;EAAA,SACtE,OAAA,GAAU,MAAA;AAAA;EAAA,SACV,OAAA,EAAS,MAAA;AAAA;;AJCxB;;UIIiB,uBAAA;EAAA,SACN,EAAA,EAAI,cAAA;EAAA,SACJ,KAAA,GAAQ,iBAAe;EAAA,SACvB,OAAA;AAAA;;AJPkD;;KIajD,uBAAA,gBAAuC,SAAA,eAAwB,SAAA,gBACzE,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,KAAA,EAAO,IAAA;AAAA;;;;KAMV,2BAAA,gBAA2C,SAAA,eAAwB,SAAA,gBAC7E,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,KAAA,EAAO,cAAA;EAAA,SACP,QAAA,GAAW,IAAA;EAAA,SACX,MAAA,GAAS,IAAA;AAAA;;AHXY;AAMpC;KGWY,uBAAA,gBAAuC,SAAA,eAAwB,SAAA,gBACzE,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,IAAA;EAAA,SACA,QAAA;AAAA;;;;KAMH,mBAAA,gBAAmC,SAAA,eAAwB,SAAA,gBACnE,uBAAA,CAAwB,MAAA,IACxB,2BAAA,CAA4B,MAAA,IAC5B,uBAAA,CAAwB,MAAA;;;;KAKhB,iBAAA,gBAAiC,SAAA,eAAwB,SAAA,gBACjE,mBAAA,CAAoB,MAAA,aACX,mBAAA,CAAoB,MAAA;;;KCrC5B,sBAAA,kBAAwC,SAAA,iBAA0B,OAAA,EAAS,QAAQ;;;;ALhBxF;;UKuBiB,WAAA,kBACE,SAAA,eAAwB,SAAA,6BAC1B,SAAA,eAAwB,QAAA;EAAA,SAM9B,EAAA,EAAI,cAAA,CAAe,OAAA;EAAA,SACnB,MAAA,EAAQ,MAAA,CAAO,MAAA,EAAQ,QAAA;EAAA,SACvB,GAAA,EAAK,WAAA,CAAY,QAAA;EAAA,SACjB,KAAA,GAAQ,iBAAA;EAAA,SACR,KAAA,GAAQ,WAAA;EAAA,SACR,QAAA,GAAW,iBAAA,CAAkB,MAAA;EAAA,SAC7B,YAAA,GAAe,cAAA,CAAe,aAAA,IAAiB,sBAAA,CAAuB,QAAA;EAAA,SACtE,cAAA,GAAiB,cAAA,CAAe,eAAA,IAAmB,sBAAA,CAAuB,QAAA;EAAA,SAC1E,iBAAA,GAAoB,iBAAA;EAAA,SACpB,cAAA,GAAiB,cAAA,CAAe,eAAA,IAAmB,sBAAA,CAAuB,QAAA;AAAA;;;;UAMpE,IAAA,kBACE,SAAA,eAAwB,SAAA,6BAC1B,SAAA,eAAwB,QAAA,UAC/B,IAAA,CAAK,WAAA,CAAY,QAAA,EAAU,MAAA;EAAA,SAC1B,EAAA,EAAI,MAAA;EAAA,SACJ,KAAA,GAAQ,iBAAA;AAAA;;AJnCiB;AAMpC;;;;;UIuCiB,qBAAA;EAAA,SACN,EAAA,EAAI,cAAA;EAAA,SACJ,MAAA,EAAQ,MAAA,UAAgB,SAAA;EAAA,SACxB,GAAA,GAAM,OAAA,SAAgB,OAAA,EAAS,WAAA,KAAgB,UAAA,CAAW,WAAA,CAAY,SAAA;EAAA,SACtE,KAAA,GAAQ,iBAAA;EAAA,SACR,KAAA,GAAQ,WAAA;EAAA,SACR,QAAA,GAAW,iBAAA;EAAA,SACX,YAAA,GAAe,cAAA,GAAiB,sBAAA;EAAA,SAChC,cAAA,GAAiB,cAAA,GAAiB,sBAAA;EAAA,SAClC,iBAAA,GAAoB,iBAAA;EAAA,SACpB,cAAA,GAAiB,cAAA,GAAiB,sBAAA;AAAA;;;;iBAkH7B,IAAA,kBACG,SAAA,6BACF,SAAA,eAAwB,QAAA,mLAAA,CAMvC,UAAA,EAAY,WAAA,CAAY,QAAA,EAAU,MAAA,EAAQ,OAAA,EAAS,aAAA,EAAe,eAAA,EAAiB,eAAA,IAClF,IAAA,CAAK,QAAA,EAAU,MAAA;;;cC9LZ,mCAAA,EAAmC,CAAA,CAAA,SAAA;;;ANJzC;;;AAAA,KMWY,0BAAA,GAA6B,CAAA,CAAE,KAAK,QAAQ,mCAAA;;;;UAKvC,yBAAA;EACf,KAAA,kBAAuB,SAAA,6BAAsC,SAAA,cAC3D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,GAC/B,OAAA,EAAS,0BAAA,GACR,OAAA;AAAA;;;;;ANpBwD;UOuC5C,uBAAA;EAAA,SACN,UAAA,EAAY,kBAAA;EAAA,SACZ,GAAA,EAAK,SAAS;AAAA;;;;UAMR,0BAAA;EAAA,SACN,YAAA,WAAuB,uBAAuB;AAAA;;;;;APhDzD;UQ2BiB,iBAAA;EAAA,SACN,YAAA,WAAuB,mBAAA;EAAA,SACvB,MAAA,WAAiB,mBAAA;EAAA,SACjB,SAAA,WAAoB,eAAA;AAAA;;;AR9B8B;UQoC5C,UAAA;EAAA,SACN,sBAAA,WAAiC,SAAA;EAAA,SACjC,iBAAA,WAA4B,SAAA;EAAA,SAC5B,YAAA,EAAc,0BAAA;EAAA,SACd,MAAA,EAAQ,iBAAA;AAAA;;;;KAMP,WAAA,GAAc,CAAA,CAAE,KAAK,QAAQ,oBAAA;;;;cAQ5B,oBAAA,EAAoB,CAAA,CAAA,SAAA;;;;;;;;cCapB,wBAAA,EAAwB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAmBzB,eAAA,GAAkB,CAAA,CAAE,KAAK,QAAQ,wBAAA;AAAA,cAEhC,6BAAA,EAA6B,CAAA,CAAA,SAAA;;;;;AN/E9B;AAMZ;;AANY,KMiGA,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,6BAAA;AAAA,cAErC,8BAAA,EAA8B,CAAA,CAAA,SAAA;;;;;;;KAQ/B,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,8BAAA;AAAA,cAEtC,6BAAA,EAA6B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;KAY9B,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,6BAAA;AAAA,cAarC,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;ALhJR;KKuJlB,gBAAA,GAAmB,CAAA,CAAE,KAAK,QAAQ,yBAAA;AAAA,cAEjC,+BAAA,EAA+B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;ALlI5C;;;AAAA,KK0IY,sBAAA,GAAyB,CAAA,CAAE,KAAK,QAAQ,+BAAA;AAAA,cAavC,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;KAe1B,gBAAA,GAAmB,CAAA,CAAE,KAAK,QAAQ,yBAAA;;;AT5L9C;;;AAAA,UU2DiB,cAAA;EACf,QAAA,CAAS,KAAA,EAAO,KAAA,GAAQ,OAAA,UAAiB,iBAAA;EACzC,MAAA,CAAO,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,gBAAA,GAAmB,OAAA,CAAQ,SAAA;EAC1D,MAAA,CAAO,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,oBAAA,GAAuB,OAAA,CAAQ,IAAA,CAAK,cAAA;EACnE,UAAA,CAAW,OAAA,EAAS,oBAAA,GAAuB,OAAA,CAAQ,SAAA;EACnD,WAAA,CAAY,OAAA,EAAS,qBAAA,GAAwB,OAAA,CAAQ,SAAA;EACrD,GAAA,CAAI,KAAA,EAAO,KAAA,GAAQ,OAAA,CAAQ,SAAA;EAC3B,IAAA,CAAK,OAAA,GAAU,eAAA,GAAkB,OAAA,CAAQ,IAAA,CAAK,UAAA;EAC9C,KAAA,CAAM,OAAA,EAAS,gBAAA,GAAmB,OAAA,CAAQ,eAAA;EAC1C,KAAA,CAAM,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,SAAA;EAC/D,KAAA,CAAM,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,SAAA;AAAA;AAAA,UAahD,iBAAA;EAAA,SACN,OAAA;EAAA,SACA,WAAA,GAAc,IAAA;EAAA,SACd,OAAA,GAAU,UAAA;EAAA,SACV,OAAA;IAAA,SACE,KAAA;IAAA,SACA,MAAA;IAAA,SACA,QAAA,EAAU,IAAA;EAAA;EAAA,SAEZ,KAAA;IAAA,SACE,KAAA;IAAA,SACA,OAAA,EAAS,IAAA;EAAA;EAAA,SAEX,SAAA,EAAW,IAAA;EAAA,SACX,MAAA,EAAQ,gBAAA;AAAA;;;;;;aC5EP,UAAA;EACV,KAAA;EACA,IAAI;AAAA;;;;UAmBI,iBAAA,SAA0B,qBAAA;EAAA,SACzB,WAAA;EV1BiB;;AAAQ;EAAR,SU8BjB,aAAA,IAAiB,GAAA,EAAK,SAAA,KAAc,SAAA;AAAA;;;;;;;UAS9B,iBAAA,SAA0B,iBAAA;EAAA,SAChC,cAAA,GAAiB,cAAA;EAAA,SACjB,IAAA,GAAO,UAAA,CAAW,IAAA;AAAA;AT5D7B;;;;AAQ0B;;AAR1B,USqEiB,kBAAA,SAA2B,iBAAiB;EAAA,SAClD,OAAA;EAAA,SACA,IAAA,EAAM,UAAA,CAAW,KAAA;AAAA;;;;KAMhB,aAAA,GAAgB,kBAAA,GAAqB,iBAAiB;;;;UAKjD,aAAA;EAAA,SACN,MAAA,EAAQ,OAAA;EAAA,SACR,IAAA,EAAM,UAAA;EAAA,SACN,MAAA,YAAkB,iBAAA;EAAA,SAClB,QAAA,EAAU,QAAA;EACnB,IAAA,IAAQ,OAAA;AAAA;;;cCwDJ,2BAAA,EAA2B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;cA0B3B,sBAAA,EAAsB,CAAA,CAAA,OAAA,CAAA,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;cAWtB,yBAAA,EAAyB,CAAA,CAAA,OAAA,CAAA,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAoB1B,gBAAA,GAAmB,QAAA,CAAS,MAAA,SAAe,qBAAA;AAAA,KAC3C,mBAAA,YAA+B,qBAAA,KAA0B,gBAAgB;AAAA,cAYxE,0BAAA,EAA0B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAkCpB,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,0BAAA;;;;KAKtC,iBAAA,GAAoB,CAAA,CAAE,KAAK,QAAQ,2BAAA;;;;KAKnC,aAAA,GAAgB,CAAA,CAAE,KAAK,QAAQ,sBAAA;;;;KAK/B,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,yBAAA;AAAA,KAO9C,cAAA,gBAA8B,SAAA,kCAA2C,MAAA,IACzE,OAAA,GAAU,MAAA,EAAQ,OAAA,GAAU,iBAAA,KAC5B,OAAA,EAAS,MAAA,EAAQ,OAAA,GAAU,iBAAA;AAAA,KAE3B,UAAA,gBAA0B,SAAA,kCAA2C,MAAA,IACrE,OAAA,GAAU,MAAA,EAAQ,OAAA,GAAU,aAAA,KAC5B,OAAA,EAAS,MAAA,EAAQ,OAAA,GAAU,aAAA;AAAA,KAE3B,uBAAA,aAAoC,QAAA;EAAA,SAA4B,KAAA;AAAA,IACjE,MAAA,GACA,QAAA;EAAA,SAA4B,KAAA;AAAA,IAC1B,MAAA;;;;UAMW,cAAA,UAAwB,mBAAA;;;;WAI9B,WAAA,EAAa,WAAA;;;AH5NxB;WGgOW,eAAA,EAAiB,yBAAA;;;;WAIjB,IAAA,EAAM,IAAA;;;;WAIN,MAAA,WAAiB,iBAAA;;;;WAIjB,IAAA,EAAM,cAAA;;;;;;WAMN,KAAA,EAAO,MAAA;;;;EAIhB,KAAA,IAAS,OAAA;;;;EAIT,KAAA,IAAS,OAAA;;;;EAIT,OAAA,kBAAyB,SAAA,6BAAsC,SAAA,cAC7D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,MAC5B,IAAA,EAAM,cAAA,CAAe,MAAA,IACvB,OAAA,CAAQ,gBAAA;;;;EAIX,MAAA,kBAAwB,SAAA,6BAAsC,SAAA,cAC5D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,MAC5B,IAAA,EAAM,UAAA,CAAW,MAAA,IACnB,OAAA,CAAQ,SAAA;;;;EAIX,IAAA,CAAK,OAAA,GAAU,WAAA,GAAc,OAAA,CAAQ,UAAA;;;;EAIrC,eAAA,CAAgB,OAAA,EAAS,eAAA,EAAiB,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,qBAAA;;;;EAIrF,WAAA,CAAY,OAAA,GAAU,qBAAA,GAAwB,OAAA,CAAQ,SAAA;;;;EAItD,MAAA,CAAO,OAAA,GAAU,aAAA,GAAgB,aAAA;AAAA;;;;;;iBA0NnB,aAAA,wBAAqC,oBAAA,CAAA,CACnD,OAAA,EAAS,QAAA,GACR,cAAA,CAAe,uBAAA,CAAwB,QAAA;AAAA,iBAC1B,aAAA,CAAc,OAAA,EAAS,oBAAA,GAAuB,cAAc;;;cC7jBtE,iCAAA,EAAiC,CAAA,CAAA,OAAA,QAAA,mBAAA;;;;cAK1B,uBAAA,EAAuB,CAAA,CAAA,SAAA;;;;;;KAOxB,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,uBAAA;;AbPU;;KaYjD,wBAAA,GAA2B,CAAA,CAAE,KAAK,QAAQ,iCAAA"}

dist/index.d.mts

@@ -1,2 +0,3 @@
-import { ActorType, DeliveryMessage, DurationString, Environment, ExecuteDeliveryOptions, FailedWakeupPublish, IdempotencyKeyTTL, JsonValue, Lane, Page, PruneRunsResult, PublishedWakeup, QueueDefinition, QueueDefinition as QueueDefinition$1, QueueOptions, RetryPolicy, RunAttemptStatus, RunEvent, RunEventRecord, RunEventSortField, RunEventType, RunFailure, RunId, RunRecord, RunSortField, RunStatus, RunSummary, RunlaneError, RunlaneIdInput, ScheduleOccurrence, Schema, SortDirection, TaskContext, TaskHandler, TaskId, TerminalRunStatus, TriggerDispatchMode, WorkerId } from "@runlane/contracts";
+import { ActorType, DeliveryMessage, DurationString, Environment, ExecuteDeliveryOptions, FailedWakeupPublish, IdempotencyKeyTTL, JsonValue, Lane, Page, PruneRunsResult, PublishedWakeup, QueueDefinition, QueueDefinition as QueueDefinition$1, QueueOptions, RetryPolicy, RunAttemptStatus, RunEvent, RunEventRecord, RunEventSortField, RunEventType, RunFailure, RunId, RunRecord, RunSortField, RunStatus, RunSummary, RunlaneError, RunlaneIdInput, ScheduleOccurrence, Schema, SortDirection, TaskContext, TaskHandler, TaskId, TriggerDispatchMode, TriggerRunResult, WorkerId } from "@runlane/contracts";
+import { Awaitable } from "@runlane/utilities";
 import * as z from "zod";
@@ -28,2 +29,20 @@ export * from "@runlane/contracts";
 //#endregion
+//#region src/runtime/lease-timing.d.ts
+/**
+ * Lease timing resolved before a run is claimed.
+ *
+ * Runtime execution uses this single value object for the initial lease claim and every heartbeat so the lease duration
+ * cannot drift during one task attempt.
+ */
+interface LeaseTiming {
+  /**
+   * Milliseconds to wait between durable `run.lease_heartbeat` events.
+   */
+  readonly heartbeatIntervalMs: number;
+  /**
+   * Milliseconds added to each claim or heartbeat timestamp to produce the next lease expiry.
+   */
+  readonly leaseDurationMs: number;
+}
+//#endregion
 //#region src/runtime-delivery.d.ts
@@ -230,3 +249,3 @@ /**
   limit: z.ZodOptional<z.ZodNumber>;
-  queues: z.ZodOptional<z.ZodPipe<z.ZodArray<z.ZodPipe<z.ZodObject<{
+  queues: z.ZodOptional<z.ZodReadonly<z.ZodArray<z.ZodPipe<z.ZodObject<{
     concurrencyLimit: z.ZodOptional<z.ZodNumber>;
@@ -252,13 +271,3 @@ default: z.ZodOptional<z.ZodBoolean>;
     } | undefined;
-  }>>>, z.ZodTransform<readonly {
-    concurrencyLimit: number | undefined;
-    default: boolean;
-    dispatchTimeout: `${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s` | undefined;
-    name: import("@runlane/contracts").Id<"queue">;
-  }[], {
-    concurrencyLimit: number | undefined;
-    default: boolean;
-    dispatchTimeout: `${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s` | undefined;
-    name: import("@runlane/contracts").Id<"queue">;
-  }[]>>>;
+  }>>>>>;
   runAt: z.ZodOptional<z.ZodObject<{
@@ -272,4 +281,4 @@ from: z.ZodOptional<z.ZodDate>;
   sourceRunId: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<import("@runlane/contracts").Id<"run">, string>>>;
-  statuses: z.ZodOptional<z.ZodPipe<z.ZodArray<z.ZodEnum<typeof RunStatus>>, z.ZodTransform<readonly RunStatus[], RunStatus[]>>>;
-  taskIds: z.ZodOptional<z.ZodPipe<z.ZodArray<z.ZodPipe<z.ZodString, z.ZodTransform<import("@runlane/contracts").Id<"task">, string>>>, z.ZodTransform<readonly TaskId[], import("@runlane/contracts").Id<"task">[]>>>;
+  statuses: z.ZodOptional<z.ZodReadonly<z.ZodArray<z.ZodEnum<typeof RunStatus>>>>;
+  taskIds: z.ZodOptional<z.ZodReadonly<z.ZodArray<z.ZodPipe<z.ZodString, z.ZodTransform<import("@runlane/contracts").Id<"task">, string>>>>>;
   updatedAt: z.ZodOptional<z.ZodObject<{
@@ -283,3 +292,3 @@ from: z.ZodOptional<z.ZodDate>;
  */
-type ListRunsOptions = z.infer<typeof listRunsOptionsValidator>;
+type ListRunsOptions = z.input<typeof listRunsOptionsValidator>;
 declare const findActiveRunOptionsValidator: z.ZodObject<{
@@ -311,3 +320,3 @@ idempotencyKey: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<import("@runlane/contracts").Id<"idempotency_key">, string>>>;
   sortDirection: z.ZodOptional<z.ZodEnum<typeof SortDirection>>;
-  types: z.ZodOptional<z.ZodPipe<z.ZodArray<z.ZodEnum<typeof RunEventType>>, z.ZodTransform<readonly RunEventType[], RunEventType[]>>>;
+  types: z.ZodOptional<z.ZodReadonly<z.ZodArray<z.ZodEnum<typeof RunEventType>>>>;
 }, z.core.$strict>;
@@ -317,3 +326,3 @@ /**
  */
-type ListRunEventsOptions = z.infer<typeof listRunEventsOptionsValidator>;
+type ListRunEventsOptions = z.input<typeof listRunEventsOptionsValidator>;
 declare const cancelRunOptionsValidator: z.ZodObject<{
@@ -331,3 +340,3 @@ actor: z.ZodOptional<z.ZodObject<{
  */
-type CancelRunOptions = z.infer<typeof cancelRunOptionsValidator>;
+type CancelRunOptions = z.input<typeof cancelRunOptionsValidator>;
 declare const createLinkedRunOptionsValidator: z.ZodObject<{
@@ -367,3 +376,3 @@ actor: z.ZodOptional<z.ZodObject<{
  */
-type CreateLinkedRunOptions = z.infer<typeof createLinkedRunOptionsValidator>;
+type CreateLinkedRunOptions = z.input<typeof createLinkedRunOptionsValidator>;
 declare const pruneRunsOptionsValidator: z.ZodObject<{
@@ -383,3 +392,3 @@ actor: z.ZodOptional<z.ZodObject<{
   }>>]>;
-  statuses: z.ZodOptional<z.ZodPipe<z.ZodArray<z.ZodPipe<z.ZodEnum<typeof RunStatus>, z.ZodTransform<RunStatus.Cancelled | RunStatus.Failed | RunStatus.Succeeded, RunStatus>>>, z.ZodTransform<readonly TerminalRunStatus[], (RunStatus.Cancelled | RunStatus.Failed | RunStatus.Succeeded)[]>>>;
+  statuses: z.ZodOptional<z.ZodReadonly<z.ZodArray<z.ZodPipe<z.ZodEnum<typeof RunStatus>, z.ZodTransform<RunStatus.Cancelled | RunStatus.Failed | RunStatus.Succeeded, RunStatus>>>>>;
 }, z.core.$strict>;
@@ -389,3 +398,3 @@ /**
  */
-type PruneRunsOptions = z.infer<typeof pruneRunsOptionsValidator>;
+type PruneRunsOptions = z.input<typeof pruneRunsOptionsValidator>;
 //#endregion
@@ -438,2 +447,6 @@ //#region src/runtime/operator-api.d.ts
   readonly concurrency?: number;
+  /**
+   * Called after a worker slot executes one run attempt and persists its final state.
+   */
+  readonly onRunExecuted?: (run: RunRecord) => Awaitable<void>;
 }
@@ -476,3 +489,3 @@ /**
 //#region src/runtime.d.ts
-declare const triggerOptionsValidator: z.ZodObject<{
+declare const runCreationOptionsValidator: z.ZodObject<{
   actor: z.ZodOptional<z.ZodObject<{
@@ -512,18 +525,115 @@ id: z.ZodOptional<z.ZodString>;
 }, z.core.$strict>;
-declare const executeNextInputValidator: z.ZodObject<{
-  heartbeatInterval: z.ZodOptional<z.ZodPipe<z.ZodPipe<z.ZodString, z.ZodTransform<{
+declare const runNowOptionsValidator: z.ZodPipe<z.ZodObject<{
+  actor: z.ZodOptional<z.ZodObject<{
+    id: z.ZodOptional<z.ZodString>;
+    type: z.ZodEnum<typeof ActorType>;
+  }, z.core.$strict>>;
+  concurrencyKey: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<import("@runlane/contracts").Id<"concurrency_key">, string>>>;
+  idempotencyKey: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<import("@runlane/contracts").Id<"idempotency_key">, string>>>;
+  idempotencyKeyTTL: z.ZodOptional<z.ZodType<import("@runlane/contracts").IdempotencyKeyTTL, unknown, z.core.$ZodTypeInternals<import("@runlane/contracts").IdempotencyKeyTTL, unknown>>>;
+  meta: z.ZodOptional<z.ZodType<import("@runlane/contracts").JsonObject, unknown, z.core.$ZodTypeInternals<import("@runlane/contracts").JsonObject, unknown>>>;
+  queue: z.ZodOptional<z.ZodPipe<z.ZodObject<{
+    concurrencyLimit: z.ZodOptional<z.ZodNumber>;
+    default: z.ZodOptional<z.ZodBoolean>;
+    dispatchTimeout: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<{
+      duration: import("@runlane/utilities").DurationString;
+      milliseconds: number;
+    }, string>>>;
+    name: z.ZodString;
+  }, z.core.$strict>, z.ZodTransform<{
+    concurrencyLimit: number | undefined;
+    default: boolean;
+    dispatchTimeout: `${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s` | undefined;
+    name: import("@runlane/contracts").Id<"queue">;
+  }, {
+    name: string;
+    concurrencyLimit?: number | undefined;
+    default?: boolean | undefined;
+    dispatchTimeout?: {
+      duration: import("@runlane/utilities").DurationString;
+      milliseconds: number;
+    } | undefined;
+  }>>>;
+  runId: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<import("@runlane/contracts").Id<"run">, string>>>;
+  singletonKey: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<import("@runlane/contracts").Id<"singleton_key">, string>>>;
+  traceCarrier: z.ZodOptional<z.ZodRecord<z.ZodString, z.ZodString>>;
+  heartbeatInterval: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<{
     duration: import("@runlane/utilities").DurationString;
     milliseconds: number;
-  }, string>>, z.ZodTransform<`${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s`, {
+  }, string>>>;
+  leaseDuration: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<{
     duration: import("@runlane/utilities").DurationString;
     milliseconds: number;
-  }>>>;
-  leaseDuration: z.ZodOptional<z.ZodPipe<z.ZodPipe<z.ZodString, z.ZodTransform<{
+  }, string>>>;
+  signal: z.ZodOptional<z.ZodType<AbortSignal, AbortSignal, z.core.$ZodTypeInternals<AbortSignal, AbortSignal>>>;
+  workerId: z.ZodOptional<z.ZodType<WorkerId, string, z.core.$ZodTypeInternals<WorkerId, string>>>;
+}, z.core.$strict>, z.ZodTransform<{
+  actor?: {
+    type: ActorType;
+    id?: string | undefined;
+  } | undefined;
+  concurrencyKey?: import("@runlane/contracts").Id<"concurrency_key"> | undefined;
+  idempotencyKey?: import("@runlane/contracts").Id<"idempotency_key"> | undefined;
+  idempotencyKeyTTL?: import("@runlane/contracts").IdempotencyKeyTTL | undefined;
+  meta?: import("@runlane/contracts").JsonObject | undefined;
+  queue?: {
+    concurrencyLimit: number | undefined;
+    default: boolean;
+    dispatchTimeout: `${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s` | undefined;
+    name: import("@runlane/contracts").Id<"queue">;
+  } | undefined;
+  runId?: import("@runlane/contracts").Id<"run"> | undefined;
+  singletonKey?: import("@runlane/contracts").Id<"singleton_key"> | undefined;
+  traceCarrier?: Record<string, string> | undefined;
+  heartbeatInterval?: {
     duration: import("@runlane/utilities").DurationString;
     milliseconds: number;
-  }, string>>, z.ZodTransform<`${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s`, {
+  } | undefined;
+  leaseDuration?: {
     duration: import("@runlane/utilities").DurationString;
     milliseconds: number;
-  }>>>;
-  queues: z.ZodOptional<z.ZodArray<z.ZodPipe<z.ZodObject<{
+  } | undefined;
+  signal?: AbortSignal | undefined;
+  workerId?: WorkerId | undefined;
+} & {
+  leaseTiming: LeaseTiming;
+}, {
+  actor?: {
+    type: ActorType;
+    id?: string | undefined;
+  } | undefined;
+  concurrencyKey?: import("@runlane/contracts").Id<"concurrency_key"> | undefined;
+  idempotencyKey?: import("@runlane/contracts").Id<"idempotency_key"> | undefined;
+  idempotencyKeyTTL?: import("@runlane/contracts").IdempotencyKeyTTL | undefined;
+  meta?: import("@runlane/contracts").JsonObject | undefined;
+  queue?: {
+    concurrencyLimit: number | undefined;
+    default: boolean;
+    dispatchTimeout: `${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s` | undefined;
+    name: import("@runlane/contracts").Id<"queue">;
+  } | undefined;
+  runId?: import("@runlane/contracts").Id<"run"> | undefined;
+  singletonKey?: import("@runlane/contracts").Id<"singleton_key"> | undefined;
+  traceCarrier?: Record<string, string> | undefined;
+  heartbeatInterval?: {
+    duration: import("@runlane/utilities").DurationString;
+    milliseconds: number;
+  } | undefined;
+  leaseDuration?: {
+    duration: import("@runlane/utilities").DurationString;
+    milliseconds: number;
+  } | undefined;
+  signal?: AbortSignal | undefined;
+  workerId?: WorkerId | undefined;
+}>>;
+declare const executeNextInputValidator: z.ZodPipe<z.ZodObject<{
+  heartbeatInterval: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<{
+    duration: import("@runlane/utilities").DurationString;
+    milliseconds: number;
+  }, string>>>;
+  leaseDuration: z.ZodOptional<z.ZodPipe<z.ZodString, z.ZodTransform<{
+    duration: import("@runlane/utilities").DurationString;
+    milliseconds: number;
+  }, string>>>;
+  queues: z.ZodOptional<z.ZodReadonly<z.ZodArray<z.ZodPipe<z.ZodObject<{
     concurrencyLimit: z.ZodOptional<z.ZodNumber>;
@@ -549,6 +659,42 @@ default: z.ZodOptional<z.ZodBoolean>;
     } | undefined;
-  }>>>>;
-  signal: z.ZodOptional<z.ZodType<AbortSignal, unknown, z.core.$ZodTypeInternals<AbortSignal, unknown>>>;
+  }>>>>>;
+  signal: z.ZodOptional<z.ZodType<AbortSignal, AbortSignal, z.core.$ZodTypeInternals<AbortSignal, AbortSignal>>>;
   workerId: z.ZodOptional<z.ZodType<WorkerId, string, z.core.$ZodTypeInternals<WorkerId, string>>>;
-}, z.core.$strict>;
+}, z.core.$strict>, z.ZodTransform<{
+  heartbeatInterval?: {
+    duration: import("@runlane/utilities").DurationString;
+    milliseconds: number;
+  } | undefined;
+  leaseDuration?: {
+    duration: import("@runlane/utilities").DurationString;
+    milliseconds: number;
+  } | undefined;
+  queues?: readonly {
+    concurrencyLimit: number | undefined;
+    default: boolean;
+    dispatchTimeout: `${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s` | undefined;
+    name: import("@runlane/contracts").Id<"queue">;
+  }[] | undefined;
+  signal?: AbortSignal | undefined;
+  workerId?: WorkerId | undefined;
+} & {
+  leaseTiming: LeaseTiming;
+}, {
+  heartbeatInterval?: {
+    duration: import("@runlane/utilities").DurationString;
+    milliseconds: number;
+  } | undefined;
+  leaseDuration?: {
+    duration: import("@runlane/utilities").DurationString;
+    milliseconds: number;
+  } | undefined;
+  queues?: readonly {
+    concurrencyLimit: number | undefined;
+    default: boolean;
+    dispatchTimeout: `${number}d` | `${number}h` | `${number}ms` | `${number}m` | `${number}s` | undefined;
+    name: import("@runlane/contracts").Id<"queue">;
+  }[] | undefined;
+  signal?: AbortSignal | undefined;
+  workerId?: WorkerId | undefined;
+}>>;
 type TaskCatalogInput = Readonly<Record<string, TaskRegistrationInput>>;
@@ -558,3 +704,3 @@ type TaskCollectionInput = readonly TaskRegistrationInput[] | TaskCatalogInput;
   clock: z.ZodOptional<z.ZodObject<{
-    now: z.ZodType<() => Date, unknown, z.core.$ZodTypeInternals<() => Date, unknown>>;
+    now: z.ZodType<() => Date, () => Date, z.core.$ZodTypeInternals<() => Date, () => Date>>;
   }, z.core.$strip>>;
@@ -580,2 +726,3 @@ dispatch: z.ZodOptional<z.ZodObject<{
         persistsOutbox: boolean;
+        processLocalState: boolean;
         prunesRuns: boolean;
@@ -601,2 +748,3 @@ readsRunHistory: boolean;
         persistsOutbox: boolean;
+        processLocalState: boolean;
         prunesRuns: boolean;
@@ -663,2 +811,3 @@ readsRunHistory: boolean;
         persistsOutbox: boolean;
+        processLocalState: boolean;
         prunesRuns: boolean;
@@ -684,2 +833,3 @@ readsRunHistory: boolean;
         persistsOutbox: boolean;
+        processLocalState: boolean;
         prunesRuns: boolean;
@@ -746,2 +896,3 @@ readsRunHistory: boolean;
         persistsOutbox: boolean;
+        processLocalState: boolean;
         prunesRuns: boolean;
@@ -767,2 +918,3 @@ readsRunHistory: boolean;
         persistsOutbox: boolean;
+        processLocalState: boolean;
         prunesRuns: boolean;
@@ -829,2 +981,3 @@ readsRunHistory: boolean;
         persistsOutbox: boolean;
+        processLocalState: boolean;
         prunesRuns: boolean;
@@ -850,2 +1003,3 @@ readsRunHistory: boolean;
         persistsOutbox: boolean;
+        processLocalState: boolean;
         prunesRuns: boolean;
@@ -932,8 +1086,13 @@ readsRunHistory: boolean;
  */
-type TriggerRunOptions = z.input<typeof triggerOptionsValidator>;
+type TriggerRunOptions = z.input<typeof runCreationOptionsValidator>;
 /**
+ * Options for durably creating and executing one run in the current process.
+ */
+type RunNowOptions = z.input<typeof runNowOptionsValidator>;
+/**
  * Options for executing one due run.
  */
-type ExecuteNextRunOptions = z.output<typeof executeNextInputValidator>;
+type ExecuteNextRunOptions = z.input<typeof executeNextInputValidator>;
 type TriggerRunArgs<TInput extends JsonValue | undefined> = undefined extends TInput ? [payload?: TInput, options?: TriggerRunOptions] : [payload: TInput, options?: TriggerRunOptions];
+type RunNowArgs<TInput extends JsonValue | undefined> = undefined extends TInput ? [payload?: TInput, options?: RunNowOptions] : [payload: TInput, options?: RunNowOptions];
 type RuntimeTasksFromOptions<TOptions> = TOptions extends {
@@ -985,4 +1144,8 @@ readonly tasks: infer TTasks;
    */
-  trigger<TPayload extends JsonValue | undefined, TInput extends JsonValue | undefined>(taskDefinition: Task<TPayload, TInput>, ...args: TriggerRunArgs<TInput>): Promise<RunRecord>;
+  trigger<TPayload extends JsonValue | undefined, TInput extends JsonValue | undefined>(taskDefinition: Task<TPayload, TInput>, ...args: TriggerRunArgs<TInput>): Promise<TriggerRunResult>;
   /**
+   * Validates payload input, creates one durable run with an owned lease, and executes exactly one attempt immediately.
+   */
+  runNow<TPayload extends JsonValue | undefined, TInput extends JsonValue | undefined>(taskDefinition: Task<TPayload, TInput>, ...args: RunNowArgs<TInput>): Promise<RunRecord>;
+  /**
    * Runs one maintenance pass over registered schedules, due waiting runs, expired leases, and pending outbox rows.
@@ -1029,3 +1192,3 @@ */
 //#endregion
-export { type CancelRunOptions, type CreateLinkedRunOptions, type CreateRunlaneOptions, type CronTaskScheduleOptions, type DispatchPolicyOptions, type DrainWorkerOptions, ExecuteDeliveryIgnoredReason, type ExecuteDeliveryResult, ExecuteDeliveryStatus, type ExecuteNextRunOptions, type IntervalTaskScheduleOptions, type ListRunEventsOptions, type ListRunsOptions, type OnceTaskScheduleOptions, type OutboxFlushResult, type PollWorkerOptions, type ProjectRunEventsCommand, type PruneRunsOptions, type QueueDefinition, type QueueOptions, type ResetIdempotencyKeyOptions, type RunAttemptSummary, type RunlaneIdempotencyKeysApi, type RunlaneRunsApi, type RunlaneRuntime, type RunlaneWorker, type ScheduleMaterialization, type Task, type TaskContext, type TaskHandler, type TaskOptions, type TaskRegistrationInput, type TaskScheduleInput, type TaskScheduleOptions, type TaskScheduleOptionsBase, type TickOptions, type TickResult, type TriggerDispatchModeInput, type TriggerRunOptions, WorkerMode, type WorkerOptions, createRunlane, projectRunEvents, queue, task };
+export { type CancelRunOptions, type CreateLinkedRunOptions, type CreateRunlaneOptions, type CronTaskScheduleOptions, type DispatchPolicyOptions, type DrainWorkerOptions, ExecuteDeliveryIgnoredReason, type ExecuteDeliveryResult, ExecuteDeliveryStatus, type ExecuteNextRunOptions, type IntervalTaskScheduleOptions, type ListRunEventsOptions, type ListRunsOptions, type OnceTaskScheduleOptions, type OutboxFlushResult, type PollWorkerOptions, type ProjectRunEventsCommand, type PruneRunsOptions, type QueueDefinition, type QueueOptions, type ResetIdempotencyKeyOptions, type RunAttemptSummary, type RunNowOptions, type RunlaneIdempotencyKeysApi, type RunlaneRunsApi, type RunlaneRuntime, type RunlaneWorker, type ScheduleMaterialization, type Task, type TaskContext, type TaskHandler, type TaskOptions, type TaskRegistrationInput, type TaskScheduleInput, type TaskScheduleOptions, type TaskScheduleOptionsBase, type TickOptions, type TickResult, type TriggerDispatchModeInput, type TriggerRunOptions, WorkerMode, type WorkerOptions, createRunlane, projectRunEvents, queue, task };
 //# sourceMappingURL=index.d.mts.map

dist/index.d.mts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.d.mts","names":[],"sources":["../src/queue.ts","../src/run-projection.ts","../src/runtime-delivery.ts","../src/schedule/types.ts","../src/task.ts","../src/runtime/idempotency-key-api.ts","../src/runtime/schedule-materialization.ts","../src/runtime/maintenance.ts","../src/runtime/operator-validation.ts","../src/runtime/operator-api.ts","../src/worker.ts","../src/runtime.ts","../src/runtime/dispatch-policy.ts"],"mappings":";;;;;;;;iBAYgB,KAAA,CAAM,OAAA,EAAS,YAAA,GAAe,eAAe;;;;;;;;AAA7D;UCaiB,uBAAA;EAAA,SACN,UAAA,GAAa,SAAA;EAAA,SACb,gBAAA;EAAA,SACA,MAAA,WAAiB,QAAQ;AAAA;;;ADhByB;iBCsB7C,gBAAA,CAAiB,OAAA,EAAS,uBAAA,GAA0B,SAAS;;;;;;aCpBjE,4BAAA;EACV,SAAA;EACA,aAAA;EACA,SAAA;EACA,MAAA;EACA,WAAA;EACA,QAAA;EACA,UAAA;AAAA;;AFT2D;;aEejD,qBAAA;EACV,QAAA;EACA,OAAO;AAAA;;;;KAMG,qBAAA;EAAA,SAEG,GAAA,EAAK,SAAA;EAAA,SACL,MAAA,EAAQ,qBAAA,CAAsB,QAAA;AAAA;EAAA,SAG9B,MAAA,EAAQ,4BAAA;EDba;AAMpC;;;EANoC,SCkBrB,GAAA,GAAM,SAAA;EAAA,SACN,MAAA,EAAQ,qBAAA,CAAsB,OAAA;AAAA;;;KCtCxC,qBAAA,gBAAqC,SAAA,kCAA2C,MAAA;EAAA,SACtE,OAAA,GAAU,MAAA;AAAA;EAAA,SACV,OAAA,EAAS,MAAA;AAAA;AHCxB;;;AAAA,UGIiB,uBAAA;EAAA,SACN,EAAA,EAAI,cAAA;EAAA,SACJ,KAAA,GAAQ,iBAAe;EAAA,SACvB,OAAA;AAAA;AHPkD;;;AAAA,KGajD,uBAAA,gBAAuC,SAAA,eAAwB,SAAA,gBACzE,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,KAAA,EAAO,IAAA;AAAA;;;;KAMV,2BAAA,gBAA2C,SAAA,eAAwB,SAAA,gBAC7E,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,KAAA,EAAO,cAAA;EAAA,SACP,QAAA,GAAW,IAAA;EAAA,SACX,MAAA,GAAS,IAAA;AAAA;AFXY;AAMpC;;AANoC,KEiBxB,uBAAA,gBAAuC,SAAA,eAAwB,SAAA,gBACzE,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,IAAA;EAAA,SACA,QAAA;AAAA;;;AFf8D;KEqBjE,mBAAA,gBAAmC,SAAA,eAAwB,SAAA,gBACnE,uBAAA,CAAwB,MAAA,IACxB,2BAAA,CAA4B,MAAA,IAC5B,uBAAA,CAAwB,MAAA;;;AD5C5B;KCiDY,iBAAA,gBAAiC,SAAA,eAAwB,SAAA,gBACjE,mBAAA,CAAoB,MAAA,aACX,mBAAA,CAAoB,MAAA;;;KCrC5B,sBAAA,kBAAwC,SAAA,iBAA0B,OAAA,EAAS,QAAQ;;;AJhBxF;;;UIuBiB,WAAA,kBACE,SAAA,eAAwB,SAAA,6BAC1B,SAAA,eAAwB,QAAA;EAAA,SAM9B,EAAA,EAAI,cAAA,CAAe,OAAA;EAAA,SACnB,MAAA,EAAQ,MAAA,CAAO,MAAA,EAAQ,QAAA;EAAA,SACvB,GAAA,EAAK,WAAA,CAAY,QAAA;EAAA,SACjB,KAAA,GAAQ,iBAAA;EAAA,SACR,KAAA,GAAQ,WAAA;EAAA,SACR,QAAA,GAAW,iBAAA,CAAkB,MAAA;EAAA,SAC7B,YAAA,GAAe,cAAA,CAAe,aAAA,IAAiB,sBAAA,CAAuB,QAAA;EAAA,SACtE,cAAA,GAAiB,cAAA,CAAe,eAAA,IAAmB,sBAAA,CAAuB,QAAA;EAAA,SAC1E,iBAAA,GAAoB,iBAAA;EAAA,SACpB,cAAA,GAAiB,cAAA,CAAe,eAAA,IAAmB,sBAAA,CAAuB,QAAA;AAAA;;;;UAMpE,IAAA,kBACE,SAAA,eAAwB,SAAA,6BAC1B,SAAA,eAAwB,QAAA,UAC/B,IAAA,CAAK,WAAA,CAAY,QAAA,EAAU,MAAA;EAAA,SAC1B,EAAA,EAAI,MAAA;EAAA,SACJ,KAAA,GAAQ,iBAAA;AAAA;AHnCiB;AAMpC;;;;;;AANoC,UG6CnB,qBAAA;EAAA,SACN,EAAA,EAAI,cAAA;EAAA,SACJ,MAAA,EAAQ,MAAA,UAAgB,SAAA;EAAA,SACxB,GAAA,GAAM,OAAA,SAAgB,OAAA,EAAS,WAAA,KAAgB,UAAA,CAAW,WAAA,CAAY,SAAA;EAAA,SACtE,KAAA,GAAQ,iBAAA;EAAA,SACR,KAAA,GAAQ,WAAA;EAAA,SACR,QAAA,GAAW,iBAAA;EAAA,SACX,YAAA,GAAe,cAAA,GAAiB,sBAAA;EAAA,SAChC,cAAA,GAAiB,cAAA,GAAiB,sBAAA;EAAA,SAClC,iBAAA,GAAoB,iBAAA;EAAA,SACpB,cAAA,GAAiB,cAAA,GAAiB,sBAAA;AAAA;;;;iBAgH7B,IAAA,kBACG,SAAA,6BACF,SAAA,eAAwB,QAAA,mLAAA,CAMvC,UAAA,EAAY,WAAA,CAAY,QAAA,EAAU,MAAA,EAAQ,OAAA,EAAS,aAAA,EAAe,eAAA,EAAiB,eAAA,IAClF,IAAA,CAAK,QAAA,EAAU,MAAA;;;cC5LZ,mCAAA,EAAmC,CAAA,CAAA,SAAA;;;;;;KAO7B,0BAAA,GAA6B,CAAA,CAAE,KAAK,QAAQ,mCAAA;;;;UAKvC,yBAAA;EACf,KAAA,kBAAuB,SAAA,6BAAsC,SAAA,cAC3D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,GAC/B,OAAA,EAAS,0BAAA,GACR,OAAA;AAAA;;;;ALpBwD;;UMuC5C,uBAAA;EAAA,SACN,UAAA,EAAY,kBAAA;EAAA,SACZ,GAAA,EAAK,SAAS;AAAA;;;;UAMR,0BAAA;EAAA,SACN,YAAA,WAAuB,uBAAuB;AAAA;;;;ANhDzD;;UO2BiB,iBAAA;EAAA,SACN,YAAA,WAAuB,mBAAA;EAAA,SACvB,MAAA,WAAiB,mBAAA;EAAA,SACjB,SAAA,WAAoB,eAAA;AAAA;;AP9B8B;;UOoC5C,UAAA;EAAA,SACN,sBAAA,WAAiC,SAAA;EAAA,SACjC,iBAAA,WAA4B,SAAA;EAAA,SAC5B,YAAA,EAAc,0BAAA;EAAA,SACd,MAAA,EAAQ,iBAAA;AAAA;;;;KAMP,WAAA,GAAc,CAAA,CAAE,KAAK,QAAQ,oBAAA;;;AN9BL;cMsCvB,oBAAA,EAAoB,CAAA,CAAA,SAAA;;;;;;;;cCgBpB,wBAAA,EAAwB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KA4BzB,eAAA,GAAkB,CAAA,CAAE,KAAK,QAAQ,wBAAA;AAAA,cAEhC,6BAAA,EAA6B,CAAA,CAAA,SAAA;;;;;;;;KAkB9B,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,6BAAA;AAAA,cAErC,8BAAA,EAA8B,CAAA,CAAA,SAAA;;;;;;ANrFS;KM6FxC,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,8BAAA;AAAA,cAEtC,6BAAA,EAA6B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;KAe9B,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,6BAAA;AAAA,cAarC,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;;KAO1B,gBAAA,GAAmB,CAAA,CAAE,KAAK,QAAQ,yBAAA;AAAA,cAEjC,+BAAA,EAA+B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAQhC,sBAAA,GAAyB,CAAA,CAAE,KAAK,QAAQ,+BAAA;AAAA,cAavC,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;KAe1B,gBAAA,GAAmB,CAAA,CAAE,KAAK,QAAQ,yBAAA;;;;;;UCjJ7B,cAAA;EACf,QAAA,CAAS,KAAA,EAAO,KAAA,GAAQ,OAAA,UAAiB,iBAAA;EACzC,MAAA,CAAO,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,gBAAA,GAAmB,OAAA,CAAQ,SAAA;EAC1D,MAAA,CAAO,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,oBAAA,GAAuB,OAAA,CAAQ,IAAA,CAAK,cAAA;EACnE,UAAA,CAAW,OAAA,EAAS,oBAAA,GAAuB,OAAA,CAAQ,SAAA;EACnD,WAAA,CAAY,OAAA,EAAS,qBAAA,GAAwB,OAAA,CAAQ,SAAA;EACrD,GAAA,CAAI,KAAA,EAAO,KAAA,GAAQ,OAAA,CAAQ,SAAA;EAC3B,IAAA,CAAK,OAAA,GAAU,eAAA,GAAkB,OAAA,CAAQ,IAAA,CAAK,UAAA;EAC9C,KAAA,CAAM,OAAA,EAAS,gBAAA,GAAmB,OAAA,CAAQ,eAAA;EAC1C,KAAA,CAAM,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,SAAA;EAC/D,KAAA,CAAM,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,SAAA;AAAA;AAAA,UAahD,iBAAA;EAAA,SACN,OAAA;EAAA,SACA,WAAA,GAAc,IAAA;EAAA,SACd,OAAA,GAAU,UAAA;EAAA,SACV,OAAA;IAAA,SACE,KAAA;IAAA,SACA,MAAA;IAAA,SACA,QAAA,EAAU,IAAA;EAAA;EAAA,SAEZ,KAAA;IAAA,SACE,KAAA;IAAA,SACA,OAAA,EAAS,IAAA;EAAA;EAAA,SAEX,SAAA,EAAW,IAAA;EAAA,SACX,MAAA,EAAQ,gBAAA;AAAA;;;;;;aC5EP,UAAA;EACV,KAAA;EACA,IAAI;AAAA;;;;UAmBI,iBAAA,SAA0B,qBAAqB;EAAA,SAC9C,WAAW;AAAA;ATzBc;AAMpC;;;;;AANoC,USkCnB,iBAAA,SAA0B,iBAAA;EAAA,SAChC,cAAA,GAAiB,cAAA;EAAA,SACjB,IAAA,GAAO,UAAA,CAAW,IAAA;AAAA;;;;ARlD7B;;;UQ2DiB,kBAAA,SAA2B,iBAAiB;EAAA,SAClD,OAAA;EAAA,SACA,IAAA,EAAM,UAAA,CAAW,KAAA;AAAA;;;;KAMhB,aAAA,GAAgB,kBAAA,GAAqB,iBAAiB;;AR5DtD;AAMZ;UQ2DiB,aAAA;EAAA,SACN,MAAA,EAAQ,OAAA;EAAA,SACR,IAAA,EAAM,UAAA;EAAA,SACN,MAAA,YAAkB,iBAAA;EAAA,SAClB,QAAA,EAAU,QAAA;EACnB,IAAA,IAAQ,OAAA;AAAA;;;cCkDJ,uBAAA,EAAuB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;cA0BvB,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAoB1B,gBAAA,GAAmB,QAAA,CAAS,MAAA,SAAe,qBAAA;AAAA,KAC3C,mBAAA,YAA+B,qBAAA,KAA0B,gBAAgB;AAAA,cAYxE,0BAAA,EAA0B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAkCpB,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,0BAAA;;;;KAKtC,iBAAA,GAAoB,CAAA,CAAE,KAAK,QAAQ,uBAAA;;;;KAKnC,qBAAA,GAAwB,CAAA,CAAE,MAAM,QAAQ,yBAAA;AAAA,KAO/C,cAAA,gBAA8B,SAAA,kCAA2C,MAAA,IACzE,OAAA,GAAU,MAAA,EAAQ,OAAA,GAAU,iBAAA,KAC5B,OAAA,EAAS,MAAA,EAAQ,OAAA,GAAU,iBAAA;AAAA,KAE3B,uBAAA,aAAoC,QAAA;EAAA,SAA4B,KAAA;AAAA,IACjE,MAAA,GACA,QAAA;EAAA,SAA4B,KAAA;AAAA,IAC1B,MAAA;;;AN3ON;UMiPiB,cAAA,UAAwB,mBAAA;;;;WAI9B,WAAA,EAAa,WAAA;ENrPgC;;AAAmC;EAAnC,SMyP7C,eAAA,EAAiB,yBAAA;ENpPc;;;EAAA,SMwP/B,IAAA,EAAM,IAAA;ENtPQ;;;EAAA,SM0Pd,MAAA,WAAiB,iBAAA;ENxPvB;;;EAAA,SM4PM,IAAA,EAAM,cAAA;EN/PT;;;;;EAAA,SMqQG,KAAA,EAAO,MAAA;ENpQiB;;;EMwQjC,KAAA,IAAS,OAAA;ENtQN;;AAAO;EM0QV,KAAA,IAAS,OAAA;;;ALvPX;EK2PE,OAAA,kBAAyB,SAAA,6BAAsC,SAAA,cAC7D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,MAC5B,IAAA,EAAM,cAAA,CAAe,MAAA,IACvB,OAAA,CAAQ,SAAA;;;;EAIX,IAAA,CAAK,OAAA,GAAU,WAAA,GAAc,OAAA,CAAQ,UAAA;ELhQ5B;;;EKoQT,eAAA,CAAgB,OAAA,EAAS,eAAA,EAAiB,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,qBAAA;EL9PtE;;;EKkQf,WAAA,CAAY,OAAA,GAAU,qBAAA,GAAwB,OAAA,CAAQ,SAAA;ELjQC;;;EKqQvD,MAAA,CAAO,OAAA,GAAU,aAAA,GAAgB,aAAA;AAAA;;;;;;iBA6MnB,aAAA,wBAAqC,oBAAA,CAAA,CACnD,OAAA,EAAS,QAAA,GACR,cAAA,CAAe,uBAAA,CAAwB,QAAA;AAAA,iBAC1B,aAAA,CAAc,OAAA,EAAS,oBAAA,GAAuB,cAAc;;;cC1gBtE,iCAAA,EAAiC,CAAA,CAAA,OAAA,QAAA,mBAAA;;;AZKvC;cYAa,uBAAA,EAAuB,CAAA,CAAA,SAAA;;;;;;KAOxB,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,uBAAA;AZPU;;;AAAA,KYYjD,wBAAA,GAA2B,CAAA,CAAE,KAAK,QAAQ,iCAAA"}
+{"version":3,"file":"index.d.mts","names":[],"sources":["../src/queue.ts","../src/run-projection.ts","../src/runtime/lease-timing.ts","../src/runtime-delivery.ts","../src/schedule/types.ts","../src/task.ts","../src/runtime/idempotency-key-api.ts","../src/runtime/schedule-materialization.ts","../src/runtime/maintenance.ts","../src/runtime/operator-validation.ts","../src/runtime/operator-api.ts","../src/worker.ts","../src/runtime.ts","../src/runtime/dispatch-policy.ts"],"mappings":";;;;;;;;;iBAYgB,KAAA,CAAM,OAAA,EAAS,YAAA,GAAe,eAAe;;;;;;;;;UCa5C,uBAAA;EAAA,SACN,UAAA,GAAa,SAAA;EAAA,SACb,gBAAA;EAAA,SACA,MAAA,WAAiB,QAAQ;AAAA;;;;iBAMpB,gBAAA,CAAiB,OAAA,EAAS,uBAAA,GAA0B,SAAS;;;;;;;;ADtB7E;UEHiB,WAAA;;;;WAIN,mBAAA;EFDmC;;AAAe;EAAf,SEKnC,eAAe;AAAA;;;;;;aCHd,4BAAA;EACV,SAAA;EACA,aAAA;EACA,SAAA;EACA,MAAA;EACA,WAAA;EACA,QAAA;EACA,UAAA;AAAA;;;AHT2D;aGejD,qBAAA;EACV,QAAA;EACA,OAAO;AAAA;;;;KAMG,qBAAA;EAAA,SAEG,GAAA,EAAK,SAAA;EAAA,SACL,MAAA,EAAQ,qBAAA,CAAsB,QAAA;AAAA;EAAA,SAG9B,MAAA,EAAQ,4BAAA;EFba;AAAA;AAMpC;;EANoC,SEkBrB,GAAA,GAAM,SAAA;EAAA,SACN,MAAA,EAAQ,qBAAA,CAAsB,OAAA;AAAA;;;KCtCxC,qBAAA,gBAAqC,SAAA,kCAA2C,MAAA;EAAA,SACtE,OAAA,GAAU,MAAA;AAAA;EAAA,SACV,OAAA,EAAS,MAAA;AAAA;;AJCxB;;UIIiB,uBAAA;EAAA,SACN,EAAA,EAAI,cAAA;EAAA,SACJ,KAAA,GAAQ,iBAAe;EAAA,SACvB,OAAA;AAAA;;AJPkD;;KIajD,uBAAA,gBAAuC,SAAA,eAAwB,SAAA,gBACzE,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,KAAA,EAAO,IAAA;AAAA;;;;KAMV,2BAAA,gBAA2C,SAAA,eAAwB,SAAA,gBAC7E,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,KAAA,EAAO,cAAA;EAAA,SACP,QAAA,GAAW,IAAA;EAAA,SACX,MAAA,GAAS,IAAA;AAAA;;AHXY;AAMpC;KGWY,uBAAA,gBAAuC,SAAA,eAAwB,SAAA,gBACzE,uBAAA,GACE,qBAAA,CAAsB,MAAA;EAAA,SACX,IAAA;EAAA,SACA,QAAA;AAAA;;;;KAMH,mBAAA,gBAAmC,SAAA,eAAwB,SAAA,gBACnE,uBAAA,CAAwB,MAAA,IACxB,2BAAA,CAA4B,MAAA,IAC5B,uBAAA,CAAwB,MAAA;;;;KAKhB,iBAAA,gBAAiC,SAAA,eAAwB,SAAA,gBACjE,mBAAA,CAAoB,MAAA,aACX,mBAAA,CAAoB,MAAA;;;KCrC5B,sBAAA,kBAAwC,SAAA,iBAA0B,OAAA,EAAS,QAAQ;;;;ALhBxF;;UKuBiB,WAAA,kBACE,SAAA,eAAwB,SAAA,6BAC1B,SAAA,eAAwB,QAAA;EAAA,SAM9B,EAAA,EAAI,cAAA,CAAe,OAAA;EAAA,SACnB,MAAA,EAAQ,MAAA,CAAO,MAAA,EAAQ,QAAA;EAAA,SACvB,GAAA,EAAK,WAAA,CAAY,QAAA;EAAA,SACjB,KAAA,GAAQ,iBAAA;EAAA,SACR,KAAA,GAAQ,WAAA;EAAA,SACR,QAAA,GAAW,iBAAA,CAAkB,MAAA;EAAA,SAC7B,YAAA,GAAe,cAAA,CAAe,aAAA,IAAiB,sBAAA,CAAuB,QAAA;EAAA,SACtE,cAAA,GAAiB,cAAA,CAAe,eAAA,IAAmB,sBAAA,CAAuB,QAAA;EAAA,SAC1E,iBAAA,GAAoB,iBAAA;EAAA,SACpB,cAAA,GAAiB,cAAA,CAAe,eAAA,IAAmB,sBAAA,CAAuB,QAAA;AAAA;;;;UAMpE,IAAA,kBACE,SAAA,eAAwB,SAAA,6BAC1B,SAAA,eAAwB,QAAA,UAC/B,IAAA,CAAK,WAAA,CAAY,QAAA,EAAU,MAAA;EAAA,SAC1B,EAAA,EAAI,MAAA;EAAA,SACJ,KAAA,GAAQ,iBAAA;AAAA;;AJnCiB;AAMpC;;;;;UIuCiB,qBAAA;EAAA,SACN,EAAA,EAAI,cAAA;EAAA,SACJ,MAAA,EAAQ,MAAA,UAAgB,SAAA;EAAA,SACxB,GAAA,GAAM,OAAA,SAAgB,OAAA,EAAS,WAAA,KAAgB,UAAA,CAAW,WAAA,CAAY,SAAA;EAAA,SACtE,KAAA,GAAQ,iBAAA;EAAA,SACR,KAAA,GAAQ,WAAA;EAAA,SACR,QAAA,GAAW,iBAAA;EAAA,SACX,YAAA,GAAe,cAAA,GAAiB,sBAAA;EAAA,SAChC,cAAA,GAAiB,cAAA,GAAiB,sBAAA;EAAA,SAClC,iBAAA,GAAoB,iBAAA;EAAA,SACpB,cAAA,GAAiB,cAAA,GAAiB,sBAAA;AAAA;;;;iBAkH7B,IAAA,kBACG,SAAA,6BACF,SAAA,eAAwB,QAAA,mLAAA,CAMvC,UAAA,EAAY,WAAA,CAAY,QAAA,EAAU,MAAA,EAAQ,OAAA,EAAS,aAAA,EAAe,eAAA,EAAiB,eAAA,IAClF,IAAA,CAAK,QAAA,EAAU,MAAA;;;cC9LZ,mCAAA,EAAmC,CAAA,CAAA,SAAA;;;ANJzC;;;AAAA,KMWY,0BAAA,GAA6B,CAAA,CAAE,KAAK,QAAQ,mCAAA;;;;UAKvC,yBAAA;EACf,KAAA,kBAAuB,SAAA,6BAAsC,SAAA,cAC3D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,GAC/B,OAAA,EAAS,0BAAA,GACR,OAAA;AAAA;;;;;ANpBwD;UOuC5C,uBAAA;EAAA,SACN,UAAA,EAAY,kBAAA;EAAA,SACZ,GAAA,EAAK,SAAS;AAAA;;;;UAMR,0BAAA;EAAA,SACN,YAAA,WAAuB,uBAAuB;AAAA;;;;;APhDzD;UQ2BiB,iBAAA;EAAA,SACN,YAAA,WAAuB,mBAAA;EAAA,SACvB,MAAA,WAAiB,mBAAA;EAAA,SACjB,SAAA,WAAoB,eAAA;AAAA;;;AR9B8B;UQoC5C,UAAA;EAAA,SACN,sBAAA,WAAiC,SAAA;EAAA,SACjC,iBAAA,WAA4B,SAAA;EAAA,SAC5B,YAAA,EAAc,0BAAA;EAAA,SACd,MAAA,EAAQ,iBAAA;AAAA;;;;KAMP,WAAA,GAAc,CAAA,CAAE,KAAK,QAAQ,oBAAA;;;;cAQ5B,oBAAA,EAAoB,CAAA,CAAA,SAAA;;;;;;;;cCapB,wBAAA,EAAwB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAmBzB,eAAA,GAAkB,CAAA,CAAE,KAAK,QAAQ,wBAAA;AAAA,cAEhC,6BAAA,EAA6B,CAAA,CAAA,SAAA;;;;;AN/E9B;AAMZ;;AANY,KMiGA,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,6BAAA;AAAA,cAErC,8BAAA,EAA8B,CAAA,CAAA,SAAA;;;;;;;KAQ/B,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,8BAAA;AAAA,cAEtC,6BAAA,EAA6B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;KAY9B,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,6BAAA;AAAA,cAarC,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;ALhJR;KKuJlB,gBAAA,GAAmB,CAAA,CAAE,KAAK,QAAQ,yBAAA;AAAA,cAEjC,+BAAA,EAA+B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;ALlI5C;;;AAAA,KK0IY,sBAAA,GAAyB,CAAA,CAAE,KAAK,QAAQ,+BAAA;AAAA,cAavC,yBAAA,EAAyB,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;KAe1B,gBAAA,GAAmB,CAAA,CAAE,KAAK,QAAQ,yBAAA;;;AT5L9C;;;AAAA,UU2DiB,cAAA;EACf,QAAA,CAAS,KAAA,EAAO,KAAA,GAAQ,OAAA,UAAiB,iBAAA;EACzC,MAAA,CAAO,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,gBAAA,GAAmB,OAAA,CAAQ,SAAA;EAC1D,MAAA,CAAO,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,oBAAA,GAAuB,OAAA,CAAQ,IAAA,CAAK,cAAA;EACnE,UAAA,CAAW,OAAA,EAAS,oBAAA,GAAuB,OAAA,CAAQ,SAAA;EACnD,WAAA,CAAY,OAAA,EAAS,qBAAA,GAAwB,OAAA,CAAQ,SAAA;EACrD,GAAA,CAAI,KAAA,EAAO,KAAA,GAAQ,OAAA,CAAQ,SAAA;EAC3B,IAAA,CAAK,OAAA,GAAU,eAAA,GAAkB,OAAA,CAAQ,IAAA,CAAK,UAAA;EAC9C,KAAA,CAAM,OAAA,EAAS,gBAAA,GAAmB,OAAA,CAAQ,eAAA;EAC1C,KAAA,CAAM,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,SAAA;EAC/D,KAAA,CAAM,KAAA,EAAO,KAAA,EAAO,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,SAAA;AAAA;AAAA,UAahD,iBAAA;EAAA,SACN,OAAA;EAAA,SACA,WAAA,GAAc,IAAA;EAAA,SACd,OAAA,GAAU,UAAA;EAAA,SACV,OAAA;IAAA,SACE,KAAA;IAAA,SACA,MAAA;IAAA,SACA,QAAA,EAAU,IAAA;EAAA;EAAA,SAEZ,KAAA;IAAA,SACE,KAAA;IAAA,SACA,OAAA,EAAS,IAAA;EAAA;EAAA,SAEX,SAAA,EAAW,IAAA;EAAA,SACX,MAAA,EAAQ,gBAAA;AAAA;;;;;;aC5EP,UAAA;EACV,KAAA;EACA,IAAI;AAAA;;;;UAmBI,iBAAA,SAA0B,qBAAA;EAAA,SACzB,WAAA;EV1BiB;;AAAQ;EAAR,SU8BjB,aAAA,IAAiB,GAAA,EAAK,SAAA,KAAc,SAAA;AAAA;;;;;;;UAS9B,iBAAA,SAA0B,iBAAA;EAAA,SAChC,cAAA,GAAiB,cAAA;EAAA,SACjB,IAAA,GAAO,UAAA,CAAW,IAAA;AAAA;AT5D7B;;;;AAQ0B;;AAR1B,USqEiB,kBAAA,SAA2B,iBAAiB;EAAA,SAClD,OAAA;EAAA,SACA,IAAA,EAAM,UAAA,CAAW,KAAA;AAAA;;;;KAMhB,aAAA,GAAgB,kBAAA,GAAqB,iBAAiB;;;;UAKjD,aAAA;EAAA,SACN,MAAA,EAAQ,OAAA;EAAA,SACR,IAAA,EAAM,UAAA;EAAA,SACN,MAAA,YAAkB,iBAAA;EAAA,SAClB,QAAA,EAAU,QAAA;EACnB,IAAA,IAAQ,OAAA;AAAA;;;cCwDJ,2BAAA,EAA2B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;cA0B3B,sBAAA,EAAsB,CAAA,CAAA,OAAA,CAAA,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;cAWtB,yBAAA,EAAyB,CAAA,CAAA,OAAA,CAAA,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAoB1B,gBAAA,GAAmB,QAAA,CAAS,MAAA,SAAe,qBAAA;AAAA,KAC3C,mBAAA,YAA+B,qBAAA,KAA0B,gBAAgB;AAAA,cAYxE,0BAAA,EAA0B,CAAA,CAAA,SAAA;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;KAkCpB,oBAAA,GAAuB,CAAA,CAAE,KAAK,QAAQ,0BAAA;;;;KAKtC,iBAAA,GAAoB,CAAA,CAAE,KAAK,QAAQ,2BAAA;;;;KAKnC,aAAA,GAAgB,CAAA,CAAE,KAAK,QAAQ,sBAAA;;;;KAK/B,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,yBAAA;AAAA,KAO9C,cAAA,gBAA8B,SAAA,kCAA2C,MAAA,IACzE,OAAA,GAAU,MAAA,EAAQ,OAAA,GAAU,iBAAA,KAC5B,OAAA,EAAS,MAAA,EAAQ,OAAA,GAAU,iBAAA;AAAA,KAE3B,UAAA,gBAA0B,SAAA,kCAA2C,MAAA,IACrE,OAAA,GAAU,MAAA,EAAQ,OAAA,GAAU,aAAA,KAC5B,OAAA,EAAS,MAAA,EAAQ,OAAA,GAAU,aAAA;AAAA,KAE3B,uBAAA,aAAoC,QAAA;EAAA,SAA4B,KAAA;AAAA,IACjE,MAAA,GACA,QAAA;EAAA,SAA4B,KAAA;AAAA,IAC1B,MAAA;;;;UAMW,cAAA,UAAwB,mBAAA;;;;WAI9B,WAAA,EAAa,WAAA;;;AH5NxB;WGgOW,eAAA,EAAiB,yBAAA;;;;WAIjB,IAAA,EAAM,IAAA;;;;WAIN,MAAA,WAAiB,iBAAA;;;;WAIjB,IAAA,EAAM,cAAA;;;;;;WAMN,KAAA,EAAO,MAAA;;;;EAIhB,KAAA,IAAS,OAAA;;;;EAIT,KAAA,IAAS,OAAA;;;;EAIT,OAAA,kBAAyB,SAAA,6BAAsC,SAAA,cAC7D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,MAC5B,IAAA,EAAM,cAAA,CAAe,MAAA,IACvB,OAAA,CAAQ,gBAAA;;;;EAIX,MAAA,kBAAwB,SAAA,6BAAsC,SAAA,cAC5D,cAAA,EAAgB,IAAA,CAAK,QAAA,EAAU,MAAA,MAC5B,IAAA,EAAM,UAAA,CAAW,MAAA,IACnB,OAAA,CAAQ,SAAA;;;;EAIX,IAAA,CAAK,OAAA,GAAU,WAAA,GAAc,OAAA,CAAQ,UAAA;;;;EAIrC,eAAA,CAAgB,OAAA,EAAS,eAAA,EAAiB,OAAA,GAAU,sBAAA,GAAyB,OAAA,CAAQ,qBAAA;;;;EAIrF,WAAA,CAAY,OAAA,GAAU,qBAAA,GAAwB,OAAA,CAAQ,SAAA;;;;EAItD,MAAA,CAAO,OAAA,GAAU,aAAA,GAAgB,aAAA;AAAA;;;;;;iBA0NnB,aAAA,wBAAqC,oBAAA,CAAA,CACnD,OAAA,EAAS,QAAA,GACR,cAAA,CAAe,uBAAA,CAAwB,QAAA;AAAA,iBAC1B,aAAA,CAAc,OAAA,EAAS,oBAAA,GAAuB,cAAc;;;cC7jBtE,iCAAA,EAAiC,CAAA,CAAA,OAAA,QAAA,mBAAA;;;;cAK1B,uBAAA,EAAuB,CAAA,CAAA,SAAA;;;;;;KAOxB,qBAAA,GAAwB,CAAA,CAAE,KAAK,QAAQ,uBAAA;;AbPU;;KaYjD,wBAAA,GAA2B,CAAA,CAAE,KAAK,QAAQ,iCAAA"}

package.json

 {
   "name": "@runlane/core",
-  "version": "0.1.1",
+  "version": "0.2.0",
   "description": "Runlane's durable task runtime: triggers, workers, schedules, retries, idempotency, leases, and operator APIs.",
@@ -54,4 +54,4 @@ "type": "module",
     "zod": "^4.3.6",
-    "@runlane/contracts": "0.1.1",
-    "@runlane/utilities": "0.1.1"
+    "@runlane/contracts": "0.2.0",
+    "@runlane/utilities": "0.2.0"
   },
@@ -63,4 +63,4 @@ "devDependencies": {
     "@repo/vitest": "0.0.0",
-    "@runlane/local-adapters": "0.1.1",
-    "@runlane/testing": "0.1.1"
+    "@runlane/local-adapters": "0.2.0",
+    "@runlane/testing": "0.2.0"
   },
@@ -67,0 +67,0 @@ "scripts": {

No alert changes

Improved metrics

Total package byte prevSize

1241381

3.74%

Lines of code

8717

1.94%

Worsened metrics

Number of low supply chain risk alerts

8

33.33%

Dependency changes

• + Added

  @runlane/contracts@0.2.0
  (transitive)

• + Added

  @runlane/utilities@0.2.0
  (transitive)

• - Removed

  @runlane/contracts@0.1.1
  (transitive)

• - Removed

  @runlane/utilities@0.1.1
  (transitive)

• Updated

  @runlane/contracts@0.2.0

• Updated

  @runlane/utilities@0.2.0