Close httplib2 connections.
Request detailed information about the execution status of a stage of the job. EXPERIMENTAL. This API is subject to change or removal without notice.
Retrieves the next page of results.
close()
Close httplib2 connections.
getExecutionDetails(projectId, location, jobId, stageId, endTime=None, pageSize=None, pageToken=None, startTime=None, x__xgafv=None)
Request detailed information about the execution status of a stage of the job. EXPERIMENTAL. This API is subject to change or removal without notice.
Args:
projectId: string, A project id. (required)
location: string, The [regional endpoint] (https://cloud.google.com/dataflow/docs/concepts/regional-endpoints) that contains the job specified by job_id. (required)
jobId: string, The job to get execution details for. (required)
stageId: string, The stage for which to fetch information. (required)
endTime: string, Upper time bound of work items to include, by start time.
pageSize: integer, If specified, determines the maximum number of work items to return. If unspecified, the service may choose an appropriate default, or may return an arbitrarily large number of results.
pageToken: string, If supplied, this should be the value of next_page_token returned by an earlier call. This will cause the next page of results to be returned.
startTime: string, Lower time bound of work items to include, by start time.
x__xgafv: string, V1 error format.
Allowed values
1 - v1 error format
2 - v2 error format
Returns:
An object of the form:
{ # Information about the workers and work items within a stage.
"nextPageToken": "A String", # If present, this response does not contain all requested tasks. To obtain the next page of results, repeat the request with page_token set to this value.
"workers": [ # Workers that have done work on the stage.
{ # Information about a worker
"workItems": [ # Work items processed by this worker, sorted by time.
{ # Information about an individual work item execution.
"attemptId": "A String", # Attempt ID of this work item
"endTime": "A String", # 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": [ # Metrics for this work item.
{ # Describes the state of a metric.
"cumulative": True or False, # True if this metric is reported as the total cumulative aggregate value accumulated since the worker started working on this WorkItem. By default this is false, indicating that this metric is reported as a delta that is not associated with any WorkItem.
"distribution": "", # A struct value describing properties of a distribution of numeric values.
"gauge": "", # A struct value describing properties of a Gauge. Metrics of gauge type show the value of a metric across time, and is aggregated based on the newest value.
"internal": "", # Worker-computed aggregate value for internal use by the Dataflow service.
"kind": "A String", # Metric aggregation kind. The possible metric aggregation kinds are "Sum", "Max", "Min", "Mean", "Set", "And", "Or", and "Distribution". The specified aggregation kind is case-insensitive. If omitted, this is not an aggregated value but instead a single metric sample value.
"meanCount": "", # Worker-computed aggregate value for the "Mean" aggregation kind. This holds the count of the aggregated values and is used in combination with mean_sum above to obtain the actual mean aggregate value. The only possible value type is Long.
"meanSum": "", # Worker-computed aggregate value for the "Mean" aggregation kind. This holds the sum of the aggregated values and is used in combination with mean_count below to obtain the actual mean aggregate value. The only possible value types are Long and Double.
"name": { # Identifies a metric, by describing the source which generated the metric. # Name of the metric.
"context": { # Zero or more labeled fields which identify the part of the job this metric is associated with, such as the name of a step or collection. For example, built-in counters associated with steps will have context['step'] = . Counters associated with PCollections in the SDK will have context['pcollection'] = .
"a_key": "A String",
},
"name": "A String", # Worker-defined metric name.
"origin": "A String", # Origin (namespace) of metric name. May be blank for user-define metrics; will be "dataflow" for metrics defined by the Dataflow service or SDK.
},
"scalar": "", # Worker-computed aggregate value for aggregation kinds "Sum", "Max", "Min", "And", and "Or". The possible value types are Long, Double, and Boolean.
"set": "", # Worker-computed aggregate value for the "Set" aggregation kind. The only possible value type is a list of Values whose type can be Long, Double, or String, according to the metric's type. All Values in the list must be of the same type.
"updateTime": "A String", # Timestamp associated with the metric value. Optional when workers are reporting work progress; it will be filled in responses from the metrics API.
},
],
"progress": { # Information about the progress of some component of job execution. # Progress of this work item.
"currentProgress": 3.14, # The current progress of the component, in the range [0,1].
"dataPoints": [ # History of progress for the component. Points are sorted by time.
{ # A point in the timeseries.
"time": "A String", # The timestamp of the point.
"value": 3.14, # The value of the point.
},
],
},
"startTime": "A String", # Start time of this work item attempt.
"state": "A String", # State of this work item.
"stragglerInfo": { # Information useful for straggler identification and debugging. # Information about straggler detections for this work item.
"causes": { # The straggler causes, keyed by the string representation of the StragglerCause enum and contains specialized debugging information for each straggler cause.
"a_key": { # Information useful for debugging a straggler. Each type will provide specialized debugging information relevant for a particular cause. The StragglerDebuggingInfo will be 1:1 mapping to the StragglerCause enum.
"hotKey": { # Information useful for debugging a hot key detection. # Hot key debugging details.
"detectedHotKeys": { # Debugging information for each detected hot key. Keyed by a hash of the key.
"a_key": { # Information about a hot key.
"hotKeyAge": "A String", # The age of the hot key measured from when it was first detected.
"key": "A String", # A detected hot key that is causing limited parallelism. This field will be populated only if the following flag is set to true: "--enable_hot_key_logging".
"keyTruncated": True or False, # If true, then the above key is truncated and cannot be deserialized. This occurs if the key above is populated and the key size is >5MB.
},
},
},
},
},
"startTime": "A String", # The time when the work item attempt became a straggler.
},
"taskId": "A String", # Name of this work item.
},
],
"workerName": "A String", # Name of this worker
},
],
}
getExecutionDetails_next()
Retrieves the next page of results.
Args:
previous_request: The request for the previous page. (required)
previous_response: The response from the request for the previous page. (required)
Returns:
A request object that you can call 'execute()' on to request the next
page. Returns None if there are no more items in the collection.