WorkItem

import type { WorkItem } from "https://googleapis.deno.dev/v1/dataflow:v1b3.ts";

WorkItem represents basic information about a WorkItem to be executed in the cloud.

interface WorkItem {

configuration?: string;

id?: bigint;

initialReportIndex?: bigint;

jobId?: string;

leaseExpireTime?: Date;

mapTask?: MapTask;

packages?: Package[];

projectId?: string;

reportStatusInterval?: number;

seqMapTask?: SeqMapTask;

shellTask?: ShellTask;

sourceOperationTask?: SourceOperationRequest;

streamingComputationTask?: StreamingComputationTask;

streamingConfigTask?: StreamingConfigTask;

streamingSetupTask?: StreamingSetupTask;

}

§Properties

configuration?: string

[src]

Work item-specific configuration as an opaque blob.

id?: bigint

[src]

Identifies this WorkItem.

initialReportIndex?: bigint

[src]

The initial index to use when reporting the status of the WorkItem.

jobId?: string

[src]

Identifies the workflow job this WorkItem belongs to.

leaseExpireTime?: Date

[src]

Time when the lease on this Work will expire.

mapTask?: MapTask

[src]

Additional information for MapTask WorkItems.

packages?: Package[]

[src]

Any required packages that need to be fetched in order to execute this WorkItem.

projectId?: string

[src]

Identifies the cloud project this WorkItem belongs to.

reportStatusInterval?: number

[src]

Recommended reporting interval.

seqMapTask?: SeqMapTask

[src]

Additional information for SeqMapTask WorkItems.

shellTask?: ShellTask

[src]

Additional information for ShellTask WorkItems.

sourceOperationTask?: SourceOperationRequest

[src]

Additional information for source operation WorkItems.

streamingComputationTask?: StreamingComputationTask

[src]

Additional information for StreamingComputationTask WorkItems.

streamingConfigTask?: StreamingConfigTask

[src]

Additional information for StreamingConfigTask WorkItems.

streamingSetupTask?: StreamingSetupTask

[src]

Additional information for StreamingSetupTask WorkItems.