class Google::Apis::DataflowV1b3::WorkItemStatus
Conveys a worker's progress through the work described by a WorkItem
.
Attributes
True if the WorkItem
was completed (successfully or unsuccessfully). Corresponds to the JSON property `completed` @return [Boolean]
True if the WorkItem
was completed (successfully or unsuccessfully). Corresponds to the JSON property `completed` @return [Boolean]
Worker output counters for this WorkItem
. Corresponds to the JSON property `counterUpdates` @return [Array<Google::Apis::DataflowV1b3::CounterUpdate>]
When a task splits using WorkItemStatus.dynamic_source_split
, this message describes the two parts of the split relative to the description of the current task's input. Corresponds to the JSON property `dynamicSourceSplit` @return [Google::Apis::DataflowV1b3::DynamicSourceSplit]
Specifies errors which occurred during processing. If errors are provided, and completed = true, then the WorkItem
is considered to have failed. Corresponds to the JSON property `errors` @return [Array<Google::Apis::DataflowV1b3::Status>]
DEPRECATED in favor of counter_updates. Corresponds to the JSON property `metricUpdates` @return [Array<Google::Apis::DataflowV1b3::MetricUpdate>]
Obsolete in favor of ApproximateReportedProgress
and ApproximateSplitRequest
. Corresponds to the JSON property `progress` @return [Google::Apis::DataflowV1b3::ApproximateProgress]
The report index. When a WorkItem
is leased, the lease will contain an initial report index. When a WorkItem's status is reported to the system, the report should be sent with that report index, and the response will contain the index the worker should use for the next report. Reports received with unexpected index values will be rejected by the service. In order to preserve idempotency, the worker should not alter the contents of a report, even if the worker must submit the same report multiple times before getting back a response. The worker should not submit a subsequent report until the response for the previous report had been received from the service. Corresponds to the JSON property `reportIndex` @return [Fixnum]
A progress measurement of a WorkItem
by a worker. Corresponds to the JSON property `reportedProgress` @return [Google::Apis::DataflowV1b3::ApproximateReportedProgress]
Amount of time the worker requests for its lease. Corresponds to the JSON property `requestedLeaseDuration` @return [String]
DEPRECATED in favor of DynamicSourceSplit
. Corresponds to the JSON property `sourceFork` @return [Google::Apis::DataflowV1b3::SourceFork]
The result of a SourceOperationRequest
, specified in ReportWorkItemStatusRequest.source_operation when the work item is completed. Corresponds to the JSON property `sourceOperationResponse` @return [Google::Apis::DataflowV1b3::SourceOperationResponse]
Position
defines a position within a collection of data. The value can be either the end position, a key (used with ordered collections), a byte offset, or a record index. Corresponds to the JSON property `stopPosition` @return [Google::Apis::DataflowV1b3::Position]
Total time the worker spent being throttled by external systems. Corresponds to the JSON property `totalThrottlerWaitTimeSeconds` @return [Float]
Identifies the WorkItem
. Corresponds to the JSON property `workItemId` @return [String]
Public Class Methods
# File lib/google/apis/dataflow_v1b3/classes.rb, line 6137 def initialize(**args) update!(**args) end
Public Instance Methods
Update properties of this object
# File lib/google/apis/dataflow_v1b3/classes.rb, line 6142 def update!(**args) @completed = args[:completed] if args.key?(:completed) @counter_updates = args[:counter_updates] if args.key?(:counter_updates) @dynamic_source_split = args[:dynamic_source_split] if args.key?(:dynamic_source_split) @errors = args[:errors] if args.key?(:errors) @metric_updates = args[:metric_updates] if args.key?(:metric_updates) @progress = args[:progress] if args.key?(:progress) @report_index = args[:report_index] if args.key?(:report_index) @reported_progress = args[:reported_progress] if args.key?(:reported_progress) @requested_lease_duration = args[:requested_lease_duration] if args.key?(:requested_lease_duration) @source_fork = args[:source_fork] if args.key?(:source_fork) @source_operation_response = args[:source_operation_response] if args.key?(:source_operation_response) @stop_position = args[:stop_position] if args.key?(:stop_position) @total_throttler_wait_time_seconds = args[:total_throttler_wait_time_seconds] if args.key?(:total_throttler_wait_time_seconds) @work_item_id = args[:work_item_id] if args.key?(:work_item_id) end