Class GenericJob<TInput, TOutput>

constructor

• new GenericJob<TInput, TOutput>(
      input: TInput,
      streamingEnabled?: boolean,
      executor: (
          input: TInput,
          ctx: MultiModalExecutionContext,
          signal?: AbortSignal,
          onChunk?: (
              chunk: JobChunk<TOutput>,
              internalChunk?: AIResponseChunk<TOutput>,
          ) => void,
      ) => Promise<AIResponse<TOutput>>,
      hooks?: JobLifecycleHooks<TOutput>,
      maxStoredResponseChunks?: number,
      executionMetadata?: {
          capability?: CapabilityKeyType;
          maxRawBytesPerJob?: number;
          providerChain?: ProviderRef[];
          storeRawResponses?: boolean;
          stripBinaryPayloadsInSnapshotsAndTimeline?: boolean;
      },
  ): GenericJob<TInput, TOutput>

  Constructs a new GenericJob instance.

  Type Parameters

  • TInput

    The input type for the job.

  • TOutput

    The output type for the job.

  Parameters

  • input: TInput

    The job input.

  • streamingEnabled: boolean = false

    Whether streaming is enabled for this job.

  • executor: (
        input: TInput,
        ctx: MultiModalExecutionContext,
        signal?: AbortSignal,
        onChunk?: (
            chunk: JobChunk<TOutput>,
            internalChunk?: AIResponseChunk<TOutput>,
        ) => void,
    ) => Promise<AIResponse<TOutput>>

    The function to execute the job.

  • Optionalhooks: JobLifecycleHooks<TOutput>

    Optional lifecycle hooks.

  • OptionalmaxStoredResponseChunks: number

    Max number of response chunks to store.

  • OptionalexecutionMetadata: {
        capability?: CapabilityKeyType;
        maxRawBytesPerJob?: number;
        providerChain?: ProviderRef[];
        storeRawResponses?: boolean;
        stripBinaryPayloadsInSnapshotsAndTimeline?: boolean;
    }

    Optional metadata for execution (capability, provider chain, etc).

  Returns GenericJob<TInput, TOutput>

Readonlyinput

OptionalonChunk

OptionalonStatusChange

durationMs

• get durationMs(): number | undefined

  Returns number | undefined

error

• get error(): Error | undefined

  Returns Error | undefined

id

• get id(): `${string}-${string}-${string}-${string}-${string}`

  Returns `${string}-${string}-${string}-${string}-${string}`

output

• get output(): TOutput | undefined

  Returns TOutput | undefined

response

• get response(): AIResponse<TOutput> | undefined

  Internal diagnostic view of final orchestration response (read-only).

  Returns AIResponse<TOutput> | undefined

responseChunks

• get responseChunks(): readonly AIResponseChunk<TOutput>[]

  Internal diagnostic view of orchestration chunks (read-only snapshot copy).

  Returns readonly AIResponseChunk<TOutput>[]

status

• get status(): JobStatus

  Returns JobStatus

getCompletionPromise

• getCompletionPromise(): Promise<TOutput>

  Returns Promise<TOutput>

isAborted

• isAborted(): boolean

  Returns boolean

isCompleted

• isCompleted(): boolean

  Returns boolean

isErrored

• isErrored(): boolean

  Returns boolean

isPending

• isPending(): boolean

  Returns boolean

isRunning

• isRunning(): boolean

  Returns boolean

markAborted

• markAborted(reason?: Error): void

  Parameters

  • Optionalreason: Error

  Returns void

reset

• reset(): void

  Returns void

restoreFromSnapshot

• restoreFromSnapshot(snapshot: JobSnapshot<TInput, TOutput>): void

  Hydrate this job from a persisted snapshot. Internal response envelopes/chunks are intentionally not restored because rerun semantics are deterministic replay from input + executor, not raw resume.

  Parameters

  • snapshot: JobSnapshot<TInput, TOutput>

  Returns void

run

• run(
      ctx: MultiModalExecutionContext,
      signal?: AbortSignal,
      onChunk?: (chunk: JobChunk<TOutput>) => void,
  ): Promise<void>

  Run the job. NOTE: Consumers should typically call JobManager.runJob() instead of invoking this directly, to ensure proper concurrency management, hooks, and persistence.

  Parameters

  • ctx: MultiModalExecutionContext

    MultiModalExecutionContext

  • Optionalsignal: AbortSignal

    Optional abort signal

  • OptionalonChunk: (chunk: JobChunk<TOutput>) => void

    Optional streaming callback (overrides existing onChunk)

  Returns Promise<void>

toSnapshot

• toSnapshot(): JobSnapshot<TInput, TOutput>

  Returns JobSnapshot<TInput, TOutput>