#[repr(i32)]pub enum JobState {
Show 13 variants
Unknown = 0,
Stopped = 1,
Running = 2,
Done = 3,
Failed = 4,
Cancelled = 5,
Updated = 6,
Draining = 7,
Drained = 8,
Pending = 9,
Cancelling = 10,
Queued = 11,
ResourceCleaningUp = 12,
}
Expand description
Describes the overall state of a [google.dataflow.v1beta3.Job][google.dataflow.v1beta3.Job].
Variants§
Unknown = 0
The job’s run state isn’t specified.
Stopped = 1
JOB_STATE_STOPPED
indicates that the job has not
yet started to run.
Running = 2
JOB_STATE_RUNNING
indicates that the job is currently running.
Done = 3
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.
Failed = 4
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
.
Cancelled = 5
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.
Updated = 6
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
.
Draining = 7
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
.
Drained = 8
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
.
Pending = 9
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
.
Cancelling = 10
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
.
Queued = 11
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
.
ResourceCleaningUp = 12
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§
source§impl JobState
impl JobState
sourcepub fn as_str_name(&self) -> &'static str
pub fn as_str_name(&self) -> &'static str
String value of the enum field names used in the ProtoBuf definition.
The values are not transformed in any way and thus are considered stable (if the ProtoBuf definition does not change) and safe for programmatic use.
sourcepub fn from_str_name(value: &str) -> Option<Self>
pub fn from_str_name(value: &str) -> Option<Self>
Creates an enum from field names used in the ProtoBuf definition.
Trait Implementations§
source§impl Ord for JobState
impl Ord for JobState
source§impl PartialEq for JobState
impl PartialEq for JobState
source§impl PartialOrd for JobState
impl PartialOrd for JobState
1.0.0 · source§fn le(&self, other: &Rhs) -> bool
fn le(&self, other: &Rhs) -> bool
self
and other
) and is used by the <=
operator. Read moresource§impl TryFrom<i32> for JobState
impl TryFrom<i32> for JobState
§type Error = UnknownEnumValue
type Error = UnknownEnumValue
impl Copy for JobState
impl Eq for JobState
impl StructuralPartialEq for JobState
Auto Trait Implementations§
impl Freeze for JobState
impl RefUnwindSafe for JobState
impl Send for JobState
impl Sync for JobState
impl Unpin for JobState
impl UnwindSafe for JobState
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
§impl<Q, K> Comparable<K> for Q
impl<Q, K> Comparable<K> for Q
source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key
and return true
if they are equal.§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key
and return true
if they are equal.§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request