Enum googapis::google::dataflow::v1beta3::JobState [−][src]
#[repr(i32)]
pub enum JobState {
Show 13 variants
Unknown,
Stopped,
Running,
Done,
Failed,
Cancelled,
Updated,
Draining,
Drained,
Pending,
Cancelling,
Queued,
ResourceCleaningUp,
}
Expand description
Describes the overall state of a [google.dataflow.v1beta3.Job][google.dataflow.v1beta3.Job].
Variants
The job’s run state isn’t specified.
JOB_STATE_STOPPED
indicates that the job has not
yet started to run.
JOB_STATE_RUNNING
indicates that the job is currently running.
JOB_STATE_DONE
indicates 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 from JOB_STATE_RUNNING
. It may also be set via a
Cloud Dataflow UpdateJob
call, if the job has not yet reached a terminal
state.
JOB_STATE_FAILED
indicates 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 from JOB_STATE_RUNNING
.
JOB_STATE_CANCELLED
indicates that the job has been explicitly
cancelled. This is a terminal job state. This state may only be
set via a Cloud Dataflow UpdateJob
call, and only if the job has not
yet reached another terminal state.
JOB_STATE_UPDATED
indicates 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 from
JOB_STATE_RUNNING
.
JOB_STATE_DRAINING
indicates 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 Dataflow
UpdateJob
call, but only as a transition from JOB_STATE_RUNNING
. Jobs
that are draining may only transition to JOB_STATE_DRAINED
,
JOB_STATE_CANCELLED
, or JOB_STATE_FAILED
.
JOB_STATE_DRAINED
indicates 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 from JOB_STATE_DRAINING
.
JOB_STATE_PENDING
indicates that the job has been created but is not yet
running. Jobs that are pending may only transition to JOB_STATE_RUNNING
,
or JOB_STATE_FAILED
.
JOB_STATE_CANCELLING
indicates that the job has been explicitly cancelled
and is in the process of stopping. Jobs that are cancelling may only
transition to JOB_STATE_CANCELLED
or JOB_STATE_FAILED
.
JOB_STATE_QUEUED
indicates that the job has been created but is being
delayed until launch. Jobs that are queued may only transition to
JOB_STATE_PENDING
or JOB_STATE_CANCELLED
.
JOB_STATE_RESOURCE_CLEANING_UP
indicates 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.
Implementations
Trait Implementations
This method returns an ordering between self
and other
values if one exists. Read more
This method tests less than (for self
and other
) and is used by the <
operator. Read more
This method tests less than or equal to (for self
and other
) and is used by the <=
operator. Read more
This method tests greater than (for self
and other
) and is used by the >
operator. Read more
Auto Trait Implementations
impl RefUnwindSafe for JobState
impl UnwindSafe for JobState
Blanket Implementations
Mutably borrows from an owned value. Read more
Compare self to key
and return true
if they are equal.
Wrap the input message T
in a tonic::Request
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more