Definition of the job information maintained by the pipeline. Fields in this entity are retrieved from the executor API (e.g. Dataflow API).
JSON representation |
---|
{ "name": string, "id": string, "createTime": string, "endTime": string, "state": enum ( |
Fields | |
---|---|
name |
Required. The fully qualified resource name for the job. |
id |
Output only. The internal ID for the job. |
createTime |
Output only. The time of job creation. A timestamp in RFC3339 UTC "Zulu" format, with nanosecond resolution and up to nine fractional digits. Examples: |
endTime |
Output only. The time of job termination. This is absent if the job is still running. A timestamp in RFC3339 UTC "Zulu" format, with nanosecond resolution and up to nine fractional digits. Examples: |
state |
The current state of the job. |
status |
Status capturing any error code or message related to job creation or execution. |
dataflowJobDetails |
All the details that are specific to a Dataflow job. |
State
Enum lisitng all the job execution states.
Enums | |
---|---|
STATE_UNSPECIFIED |
The job state isn't specified. |
STATE_PENDING |
The job is waiting to start execution. |
STATE_RUNNING |
The job is executing. |
STATE_DONE |
The job has finished execution successfully. |
STATE_FAILED |
The job has finished execution with a failure. |
STATE_CANCELLED |
The job has been terminated upon user request. |
Status
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. 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.
JSON representation |
---|
{ "code": integer, "message": string, "details": [ { "@type": string, field1: ..., ... } ] } |
Fields | |
---|---|
code |
The status code, which should be an enum value of |
message |
A developer-facing error message, which should be in English. Any user-facing error message should be localized and sent in the |
details[] |
A list of messages that carry the error details. There is a common set of message types for APIs to use. An object containing fields of an arbitrary type. An additional field |
DataflowJobDetails
Pipeline job details specific to the Dataflow API. This is encapsulated here to allow for more executors to store their specific details separately.
JSON representation |
---|
{
"sdkVersion": {
object ( |
Fields | |
---|---|
sdkVersion |
Output only. The SDK version used to run the job. |
currentWorkers |
Output only. The current number of workers used to run the jobs. Only set to a value if the job is still running. |
resourceInfo |
Cached version of all the metrics of interest for the job. This value gets stored here when the job is terminated. As long as the job is running, this field is populated from the Dataflow API. An object containing a list of |
SdkVersion
The version of the SDK used to run the job.
JSON representation |
---|
{
"version": string,
"versionDisplayName": string,
"sdkSupportStatus": enum ( |
Fields | |
---|---|
version |
The version of the SDK used to run the job. |
versionDisplayName |
A readable string describing the version of the SDK. |
sdkSupportStatus |
The support status for this SDK version. |
SdkSupportStatus
The support status of the SDK used to run the job.
Enums | |
---|---|
UNKNOWN |
Dataflow is unaware of this version. |
SUPPORTED |
This is a known version of an SDK, and is supported. |
STALE |
A newer version of the SDK exists, and an update is recommended. |
DEPRECATED |
This version of the SDK is deprecated and will eventually be unsupported. |
UNSUPPORTED |
Support for this SDK version has ended and it should no longer be used. |