class Google::Apis::DataflowV1b3::WorkItemServiceState

The Dataflow service's idea of the current state of a WorkItem being processed by a worker.

Attributes

complete_work_status[RW]

The `Status` type defines a logical error model that is suitable for different programming environments, including REST APIs and RPC APIs. It is used by [ gRPC](github.com/grpc). Each `Status` message contains three pieces of data: error code, error message, and error details. You can find out more about this error model and how to work with it in the [API Design Guide](https: //cloud.google.com/apis/design/errors). Corresponds to the JSON property `completeWorkStatus` @return [Google::Apis::DataflowV1b3::Status]

harness_data[RW]

Other data returned by the service, specific to the particular worker harness. Corresponds to the JSON property `harnessData` @return [Hash<String,Object>]

hot_key_detection[RW]

Proto describing a hot key detected on a given WorkItem. Corresponds to the JSON property `hotKeyDetection` @return [Google::Apis::DataflowV1b3::HotKeyDetection]

lease_expire_time[RW]

Time at which the current lease will expire. Corresponds to the JSON property `leaseExpireTime` @return [String]

metric_short_id[RW]

The short ids that workers should use in subsequent metric updates. Workers should strive to use short ids whenever possible, but it is ok to request the short_id again if a worker lost track of it (e.g. if the worker is recovering from a crash). NOTE: it is possible that the response may have short ids for a subset of the metrics. Corresponds to the JSON property `metricShortId` @return [Array<Google::Apis::DataflowV1b3::MetricShortId>]

next_report_index[RW]

The index value to use for the next report sent by the worker. Note: If the report call fails for whatever reason, the worker should reuse this index for subsequent report attempts. Corresponds to the JSON property `nextReportIndex` @return [Fixnum]

report_status_interval[RW]

New recommended reporting interval. Corresponds to the JSON property `reportStatusInterval` @return [String]

split_request[RW]

A suggestion by the service to the worker to dynamically split the WorkItem. Corresponds to the JSON property `splitRequest` @return [Google::Apis::DataflowV1b3::ApproximateSplitRequest]

suggested_stop_point[RW]

Obsolete in favor of ApproximateReportedProgress and ApproximateSplitRequest. Corresponds to the JSON property `suggestedStopPoint` @return [Google::Apis::DataflowV1b3::ApproximateProgress]

suggested_stop_position[RW]

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 `suggestedStopPosition` @return [Google::Apis::DataflowV1b3::Position]

Public Class Methods

new(**args) click to toggle source
# File lib/google/apis/dataflow_v1b3/classes.rb, line 6029
def initialize(**args)
   update!(**args)
end

Public Instance Methods

update!(**args) click to toggle source

Update properties of this object

# File lib/google/apis/dataflow_v1b3/classes.rb, line 6034
def update!(**args)
  @complete_work_status = args[:complete_work_status] if args.key?(:complete_work_status)
  @harness_data = args[:harness_data] if args.key?(:harness_data)
  @hot_key_detection = args[:hot_key_detection] if args.key?(:hot_key_detection)
  @lease_expire_time = args[:lease_expire_time] if args.key?(:lease_expire_time)
  @metric_short_id = args[:metric_short_id] if args.key?(:metric_short_id)
  @next_report_index = args[:next_report_index] if args.key?(:next_report_index)
  @report_status_interval = args[:report_status_interval] if args.key?(:report_status_interval)
  @split_request = args[:split_request] if args.key?(:split_request)
  @suggested_stop_point = args[:suggested_stop_point] if args.key?(:suggested_stop_point)
  @suggested_stop_position = args[:suggested_stop_position] if args.key?(:suggested_stop_position)
end