@camunda8/orchestration-cluster-api
    Preparing search index...

    Interface JobWorkerConfig<In, Out, Headers>

    interface JobWorkerConfig<
        In extends z.ZodTypeAny = any,
        Out extends z.ZodTypeAny = any,
        Headers extends z.ZodTypeAny = any,
    > {
        autoStart?: boolean;
        customHeadersSchema?: Headers;
        fetchVariables?: In extends ZodType<
            unknown,
            unknown,
            $ZodTypeInternals<unknown, unknown>,
        >
            ? Extract<keyof output<In>, string>[]
            : string[];
        inputSchema?: In;
        jobHandler: (
            job: Job<In, Headers>,
        ) => "JOB_ACTION_RECEIPT" | Promise<"JOB_ACTION_RECEIPT">;
        jobTimeoutMs?: number;
        jobType: string;
        maxBackoffTimeMs?: number;
        maxParallelJobs?: number;
        outputSchema?: Out;
        pollIntervalMs?: number;
        pollTimeoutMs?: number;
        startupJitterMaxSeconds?: number;
        validateSchemas?: boolean;
        workerName?: string;
    }

    Type Parameters

    • In extends z.ZodTypeAny = any
    • Out extends z.ZodTypeAny = any
    • Headers extends z.ZodTypeAny = any
    Index

    Properties

    autoStart? customHeadersSchema? fetchVariables? inputSchema? jobHandler jobTimeoutMs? jobType maxBackoffTimeMs? maxParallelJobs? outputSchema? pollIntervalMs? pollTimeoutMs? startupJitterMaxSeconds? validateSchemas? workerName?

    Properties

    autoStart?: boolean

    Immediately start polling for work - default true

    customHeadersSchema?: Headers

    Zod schema for custom headers in the activated job

    fetchVariables?: In extends ZodType<
        unknown,
        unknown,
        $ZodTypeInternals<unknown, unknown>,
    >
        ? Extract<keyof output<In>, string>[]
        : string[]

    Optional list of variable names to fetch during activation

    inputSchema?: In

    Zod schema for variables in the activated job

    jobHandler: (
        job: Job<In, Headers>,
    ) => "JOB_ACTION_RECEIPT" | Promise<"JOB_ACTION_RECEIPT">
    jobTimeoutMs?: number

    Job activation timeout — falls back to CAMUNDA_WORKER_TIMEOUT env var

    jobType: string

    Zeebe job type

    maxBackoffTimeMs?: number

    Not used; pacing handled by long polling + client backpressure. Present only for migration compatibility.

    maxParallelJobs?: number

    concurrency limit — falls back to CAMUNDA_WORKER_MAX_CONCURRENT_JOBS env var

    outputSchema?: Out

    Zod schema for variables in the complete command

    pollIntervalMs?: number

    Backoff between polls - default 1ms

    pollTimeoutMs?: number

    The request will be completed when at least one job is activated or after the requestTimeout. If the requestTimeout = 0, the request will be completed after a default configured timeout in the broker. To immediately complete the request when no job is activated set the requestTimeout to a negative value

    startupJitterMaxSeconds?: number

    Maximum random delay (in seconds) before the worker starts polling. When multiple application instances restart simultaneously, this spreads out initial activation requests to avoid saturating the server. 0 (the default) means no delay.

    validateSchemas?: boolean

    Validate any provided input, output, customheader schema default: false

    workerName?: string

    Optional explicit name

    Settings

    Member Visibility

    On This Page

    Properties