class Google::Apis::DataflowV1b3::ReportWorkItemStatusRequest

Request to report the status of WorkItems.

Attributes

current_worker_time[RW]

The current timestamp at the worker. Corresponds to the JSON property `currentWorkerTime` @return [String]

location[RW]

The [regional endpoint] (cloud.google.com/dataflow/docs/concepts/ regional-endpoints) that contains the WorkItem's job. Corresponds to the JSON property `location` @return [String]

unified_worker_request[RW]

Untranslated bag-of-bytes WorkProgressUpdateRequest from UnifiedWorker. Corresponds to the JSON property `unifiedWorkerRequest` @return [Hash<String,Object>]

work_item_statuses[RW]

The order is unimportant, except that the order of the WorkItemServiceState messages in the ReportWorkItemStatusResponse corresponds to the order of WorkItemStatus messages here. Corresponds to the JSON property `workItemStatuses` @return [Array<Google::Apis::DataflowV1b3::WorkItemStatus>]

worker_id[RW]

The ID of the worker reporting the WorkItem status. If this does not match the ID of the worker which the Dataflow service believes currently has the lease on the WorkItem, the report will be dropped (with an error response). Corresponds to the JSON property `workerId` @return [String]

Public Class Methods

new(**args) click to toggle source
# File lib/google/apis/dataflow_v1b3/classes.rb, line 3726
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 3731
def update!(**args)
  @current_worker_time = args[:current_worker_time] if args.key?(:current_worker_time)
  @location = args[:location] if args.key?(:location)
  @unified_worker_request = args[:unified_worker_request] if args.key?(:unified_worker_request)
  @work_item_statuses = args[:work_item_statuses] if args.key?(:work_item_statuses)
  @worker_id = args[:worker_id] if args.key?(:worker_id)
end