Dataflow V1beta3 API - Class Google::Cloud::Dataflow::V1beta3::WorkItemDetails (v0.10.0)

Reference documentation and code samples for the Dataflow V1beta3 API class Google::Cloud::Dataflow::V1beta3::WorkItemDetails.

Information about an individual work item execution.

Inherits

  • Object

Extended By

  • Google::Protobuf::MessageExts::ClassMethods

Includes

  • Google::Protobuf::MessageExts

Methods

#attempt_id

def attempt_id() -> ::String
Returns
  • (::String) — Attempt ID of this work item

#attempt_id=

def attempt_id=(value) -> ::String
Parameter
  • value (::String) — Attempt ID of this work item
Returns
  • (::String) — Attempt ID of this work item

#end_time

def end_time() -> ::Google::Protobuf::Timestamp
Returns
  • (::Google::Protobuf::Timestamp) — End time of this work item attempt.

    If the work item is completed, this is the actual end time of the work item. Otherwise, it is the predicted end time.

#end_time=

def end_time=(value) -> ::Google::Protobuf::Timestamp
Parameter
  • value (::Google::Protobuf::Timestamp) — End time of this work item attempt.

    If the work item is completed, this is the actual end time of the work item. Otherwise, it is the predicted end time.

Returns
  • (::Google::Protobuf::Timestamp) — End time of this work item attempt.

    If the work item is completed, this is the actual end time of the work item. Otherwise, it is the predicted end time.

#metrics

def metrics() -> ::Array<::Google::Cloud::Dataflow::V1beta3::MetricUpdate>
Returns

#metrics=

def metrics=(value) -> ::Array<::Google::Cloud::Dataflow::V1beta3::MetricUpdate>
Parameter
Returns

#progress

def progress() -> ::Google::Cloud::Dataflow::V1beta3::ProgressTimeseries
Returns

#progress=

def progress=(value) -> ::Google::Cloud::Dataflow::V1beta3::ProgressTimeseries
Parameter
Returns

#start_time

def start_time() -> ::Google::Protobuf::Timestamp
Returns

#start_time=

def start_time=(value) -> ::Google::Protobuf::Timestamp
Parameter
Returns

#state

def state() -> ::Google::Cloud::Dataflow::V1beta3::ExecutionState
Returns

#state=

def state=(value) -> ::Google::Cloud::Dataflow::V1beta3::ExecutionState
Parameter
Returns

#task_id

def task_id() -> ::String
Returns
  • (::String) — Name of this work item.

#task_id=

def task_id=(value) -> ::String
Parameter
  • value (::String) — Name of this work item.
Returns
  • (::String) — Name of this work item.