#[non_exhaustive]pub struct JobScheduling {
pub max_failures_per_hour: i32,
pub max_failures_total: i32,
/* private fields */
}Expand description
Job scheduling options.
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.max_failures_per_hour: i32Optional. Maximum number of times per hour a driver can be restarted as a result of driver exiting with non-zero code before job is reported failed.
A job might be reported as thrashing if the driver exits with a non-zero code four times within a 10-minute window.
Maximum value is 10.
Note: This restartable job option is not supported in Dataproc [workflow templates] (https://cloud.google.com/dataproc/docs/concepts/workflows/using-workflows#adding_jobs_to_a_template).
max_failures_total: i32Optional. Maximum total number of times a driver can be restarted as a result of the driver exiting with a non-zero code. After the maximum number is reached, the job will be reported as failed.
Maximum value is 240.
Note: Currently, this restartable job option is not supported in Dataproc workflow templates.
Implementations§
Source§impl JobScheduling
impl JobScheduling
Sourcepub fn set_max_failures_per_hour<T: Into<i32>>(self, v: T) -> Self
pub fn set_max_failures_per_hour<T: Into<i32>>(self, v: T) -> Self
Sets the value of max_failures_per_hour.
§Example
let x = JobScheduling::new().set_max_failures_per_hour(42);Sourcepub fn set_max_failures_total<T: Into<i32>>(self, v: T) -> Self
pub fn set_max_failures_total<T: Into<i32>>(self, v: T) -> Self
Sets the value of max_failures_total.
§Example
let x = JobScheduling::new().set_max_failures_total(42);Trait Implementations§
Source§impl Clone for JobScheduling
impl Clone for JobScheduling
Source§fn clone(&self) -> JobScheduling
fn clone(&self) -> JobScheduling
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for JobScheduling
impl Debug for JobScheduling
Source§impl Default for JobScheduling
impl Default for JobScheduling
Source§fn default() -> JobScheduling
fn default() -> JobScheduling
Source§impl Message for JobScheduling
impl Message for JobScheduling
Source§impl PartialEq for JobScheduling
impl PartialEq for JobScheduling
impl StructuralPartialEq for JobScheduling
Auto Trait Implementations§
impl Freeze for JobScheduling
impl RefUnwindSafe for JobScheduling
impl Send for JobScheduling
impl Sync for JobScheduling
impl Unpin for JobScheduling
impl UnsafeUnpin for JobScheduling
impl UnwindSafe for JobScheduling
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<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
Source§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§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