currentState property
The current state of the job.
Jobs are created in the JOB_STATE_STOPPED state unless otherwise
specified. A job in the JOB_STATE_RUNNING state may asynchronously enter
a terminal state. After a job has reached a terminal state, no further
state updates may be made. This field may be mutated by the Cloud Dataflow
service; callers cannot mutate it.
Possible string values are:
- "JOB_STATE_UNKNOWN" : The job's run state isn't specified.
- "JOB_STATE_STOPPED" :
JOB_STATE_STOPPEDindicates that the job has not yet started to run. - "JOB_STATE_RUNNING" :
JOB_STATE_RUNNINGindicates that the job is currently running. - "JOB_STATE_DONE" :
JOB_STATE_DONEindicates that the job has successfully completed. This is a terminal job state. This state may be set by the Cloud Dataflow service, as a transition fromJOB_STATE_RUNNING. It may also be set via a Cloud DataflowUpdateJobcall, if the job has not yet reached a terminal state. - "JOB_STATE_FAILED" :
JOB_STATE_FAILEDindicates that the job has failed. This is a terminal job state. This state may only be set by the Cloud Dataflow service, and only as a transition fromJOB_STATE_RUNNING. - "JOB_STATE_CANCELLED" :
JOB_STATE_CANCELLEDindicates that the job has been explicitly cancelled. This is a terminal job state. This state may only be set via a Cloud DataflowUpdateJobcall, and only if the job has not yet reached another terminal state. - "JOB_STATE_UPDATED" :
JOB_STATE_UPDATEDindicates that the job was successfully updated, meaning that this job was stopped and another job was started, inheriting state from this one. This is a terminal job state. This state may only be set by the Cloud Dataflow service, and only as a transition fromJOB_STATE_RUNNING. - "JOB_STATE_DRAINING" :
JOB_STATE_DRAININGindicates that the job is in the process of draining. A draining job has stopped pulling from its input sources and is processing any data that remains in-flight. This state may be set via a Cloud DataflowUpdateJobcall, but only as a transition fromJOB_STATE_RUNNING. Jobs that are draining may only transition toJOB_STATE_DRAINED,JOB_STATE_CANCELLED, orJOB_STATE_FAILED. - "JOB_STATE_DRAINED" :
JOB_STATE_DRAINEDindicates that the job has been drained. A drained job terminated by stopping pulling from its input sources and processing any data that remained in-flight when draining was requested. This state is a terminal state, may only be set by the Cloud Dataflow service, and only as a transition fromJOB_STATE_DRAINING. - "JOB_STATE_PENDING" :
JOB_STATE_PENDINGindicates that the job has been created but is not yet running. Jobs that are pending may only transition toJOB_STATE_RUNNING, orJOB_STATE_FAILED. - "JOB_STATE_CANCELLING" :
JOB_STATE_CANCELLINGindicates that the job has been explicitly cancelled and is in the process of stopping. Jobs that are cancelling may only transition toJOB_STATE_CANCELLEDorJOB_STATE_FAILED. - "JOB_STATE_QUEUED" :
JOB_STATE_QUEUEDindicates that the job has been created but is being delayed until launch. Jobs that are queued may only transition toJOB_STATE_PENDINGorJOB_STATE_CANCELLED. - "JOB_STATE_RESOURCE_CLEANING_UP" :
JOB_STATE_RESOURCE_CLEANING_UPindicates that the batch job's associated resources are currently being cleaned up after a successful run. Currently, this is an opt-in feature, please reach out to Cloud support team if you are interested.
Implementation
core.String? currentState;