#![doc = "generated by AutoRust"]
#![allow(non_camel_case_types)]
#![allow(unused_imports)]
use serde::{Deserialize, Serialize};
#[doc = "Data Lake Analytics Job Parameters base class for build and submit."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct BaseJobParameters {
#[doc = "The job type of the current job (Hive, USql, or Scope (for internal use only))."]
#[serde(rename = "type")]
pub type_: base_job_parameters::Type,
#[doc = "The common Data Lake Analytics job properties for job submission."]
pub properties: CreateJobProperties,
}
impl BaseJobParameters {
pub fn new(type_: base_job_parameters::Type, properties: CreateJobProperties) -> Self {
Self { type_, properties }
}
}
pub mod base_job_parameters {
use super::*;
#[doc = "The job type of the current job (Hive, USql, or Scope (for internal use only))."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub enum Type {
USql,
Hive,
Scope,
}
}
#[doc = "The parameters used to build a new Data Lake Analytics job."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct BuildJobParameters {
#[serde(flatten)]
pub base_job_parameters: BaseJobParameters,
#[doc = "The friendly name of the job to build."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
}
impl BuildJobParameters {
pub fn new(base_job_parameters: BaseJobParameters) -> Self {
Self {
base_job_parameters,
name: None,
}
}
}
#[doc = "The parameters used to submit a new Data Lake Analytics job."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct CreateJobParameters {
#[serde(flatten)]
pub base_job_parameters: BaseJobParameters,
#[doc = "The friendly name of the job to submit."]
pub name: String,
#[doc = "The degree of parallelism to use for this job. At most one of degreeOfParallelism and degreeOfParallelismPercent should be specified. If none, a default value of 1 will be used for degreeOfParallelism."]
#[serde(rename = "degreeOfParallelism", default, skip_serializing_if = "Option::is_none")]
pub degree_of_parallelism: Option<i32>,
#[doc = "the degree of parallelism in percentage used for this job. At most one of degreeOfParallelism and degreeOfParallelismPercent should be specified. If none, a default value of 1 will be used for degreeOfParallelism."]
#[serde(rename = "degreeOfParallelismPercent", default, skip_serializing_if = "Option::is_none")]
pub degree_of_parallelism_percent: Option<f64>,
#[doc = "The priority value to use for the current job. Lower numbers have a higher priority. By default, a job has a priority of 1000. This must be greater than 0."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub priority: Option<i32>,
#[doc = "The list of log file name patterns to find in the logFolder. '*' is the only matching character allowed. Example format: jobExecution*.log or *mylog*.txt"]
#[serde(rename = "logFilePatterns", default, skip_serializing_if = "Vec::is_empty")]
pub log_file_patterns: Vec<String>,
#[doc = "Job relationship information properties including pipeline information, correlation information, etc."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub related: Option<JobRelationshipProperties>,
}
impl CreateJobParameters {
pub fn new(base_job_parameters: BaseJobParameters, name: String) -> Self {
Self {
base_job_parameters,
name,
degree_of_parallelism: None,
degree_of_parallelism_percent: None,
priority: None,
log_file_patterns: Vec::new(),
related: None,
}
}
}
#[doc = "The common Data Lake Analytics job properties for job submission."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct CreateJobProperties {
#[doc = "The runtime version of the Data Lake Analytics engine to use for the specific type of job being run."]
#[serde(rename = "runtimeVersion", default, skip_serializing_if = "Option::is_none")]
pub runtime_version: Option<String>,
#[doc = "The script to run. Please note that the maximum script size is 3 MB."]
pub script: String,
#[doc = "The job type of the current job (Hive, USql, or Scope (for internal use only))."]
#[serde(rename = "type")]
pub type_: String,
}
impl CreateJobProperties {
pub fn new(script: String, type_: String) -> Self {
Self {
runtime_version: None,
script,
type_,
}
}
}
#[doc = "The parameters used to submit a new Data Lake Analytics Scope job. (Only for use internally with Scope job type.)"]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct CreateScopeJobParameters {
#[serde(flatten)]
pub create_job_parameters: CreateJobParameters,
#[doc = "The key-value pairs used to add additional metadata to the job information."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub tags: Option<serde_json::Value>,
}
impl CreateScopeJobParameters {
pub fn new(create_job_parameters: CreateJobParameters) -> Self {
Self {
create_job_parameters,
tags: None,
}
}
}
#[doc = "Scope job properties used when submitting Scope jobs. (Only for use internally with Scope job type.)"]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct CreateScopeJobProperties {
#[serde(flatten)]
pub create_job_properties: CreateJobProperties,
#[doc = "The list of resources that are required by the job."]
#[serde(default, skip_serializing_if = "Vec::is_empty")]
pub resources: Vec<ScopeJobResource>,
#[doc = "The list of email addresses, separated by semi-colons, to notify when the job reaches a terminal state."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub notifier: Option<String>,
}
impl CreateScopeJobProperties {
pub fn new(create_job_properties: CreateJobProperties) -> Self {
Self {
create_job_properties,
resources: Vec::new(),
notifier: None,
}
}
}
#[doc = "U-SQL job properties used when submitting U-SQL jobs."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct CreateUSqlJobProperties {
#[serde(flatten)]
pub create_job_properties: CreateJobProperties,
#[doc = "The specific compilation mode for the job used during execution. If this is not specified during submission, the server will determine the optimal compilation mode."]
#[serde(rename = "compileMode", default, skip_serializing_if = "Option::is_none")]
pub compile_mode: Option<create_u_sql_job_properties::CompileMode>,
}
impl CreateUSqlJobProperties {
pub fn new(create_job_properties: CreateJobProperties) -> Self {
Self {
create_job_properties,
compile_mode: None,
}
}
}
pub mod create_u_sql_job_properties {
use super::*;
#[doc = "The specific compilation mode for the job used during execution. If this is not specified during submission, the server will determine the optimal compilation mode."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub enum CompileMode {
Semantic,
Full,
SingleBox,
}
}
#[doc = "Error diagnostic information for failed jobs."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct Diagnostics {
#[doc = "The error message."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub message: Option<String>,
#[doc = "The severity of the error."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub severity: Option<diagnostics::Severity>,
#[doc = "The line number the error occurred on."]
#[serde(rename = "lineNumber", default, skip_serializing_if = "Option::is_none")]
pub line_number: Option<i32>,
#[doc = "The column where the error occurred."]
#[serde(rename = "columnNumber", default, skip_serializing_if = "Option::is_none")]
pub column_number: Option<i32>,
#[doc = "The starting index of the error."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub start: Option<i32>,
#[doc = "The ending index of the error."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub end: Option<i32>,
}
impl Diagnostics {
pub fn new() -> Self {
Self::default()
}
}
pub mod diagnostics {
use super::*;
#[doc = "The severity of the error."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub enum Severity {
Warning,
Error,
Info,
SevereWarning,
Deprecated,
UserWarning,
}
}
#[doc = "Hive job properties used when retrieving Hive jobs."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct HiveJobProperties {
#[serde(flatten)]
pub job_properties: JobProperties,
#[doc = "The Hive logs location."]
#[serde(rename = "logsLocation", default, skip_serializing_if = "Option::is_none")]
pub logs_location: Option<String>,
#[doc = "The location of Hive job output files (both execution output and results)."]
#[serde(rename = "outputLocation", default, skip_serializing_if = "Option::is_none")]
pub output_location: Option<String>,
#[doc = "The number of statements that will be run based on the script."]
#[serde(rename = "statementCount", default, skip_serializing_if = "Option::is_none")]
pub statement_count: Option<i32>,
#[doc = "The number of statements that have been run based on the script."]
#[serde(rename = "executedStatementCount", default, skip_serializing_if = "Option::is_none")]
pub executed_statement_count: Option<i32>,
}
impl HiveJobProperties {
pub fn new(job_properties: JobProperties) -> Self {
Self {
job_properties,
logs_location: None,
output_location: None,
statement_count: None,
executed_statement_count: None,
}
}
}
#[doc = "A Data Lake Analytics job data path item."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct JobDataPath {
#[doc = "The ID of the job this data is for."]
#[serde(rename = "jobId", default, skip_serializing_if = "Option::is_none")]
pub job_id: Option<String>,
#[doc = "The command that this job data relates to."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub command: Option<String>,
#[doc = "The list of paths to all of the job data."]
#[serde(default, skip_serializing_if = "Vec::is_empty")]
pub paths: Vec<String>,
}
impl JobDataPath {
pub fn new() -> Self {
Self::default()
}
}
#[doc = "The Data Lake Analytics job error details."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct JobErrorDetails {
#[doc = "The specific identifier for the type of error encountered in the job."]
#[serde(rename = "errorId", default, skip_serializing_if = "Option::is_none")]
pub error_id: Option<String>,
#[doc = "The severity level of the failure."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub severity: Option<job_error_details::Severity>,
#[doc = "The ultimate source of the failure (usually either SYSTEM or USER)."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub source: Option<String>,
#[doc = "The user friendly error message for the failure."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub message: Option<String>,
#[doc = "The error message description."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[doc = "The details of the error message."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub details: Option<String>,
#[doc = "The specific line number in the job where the error occurred."]
#[serde(rename = "lineNumber", default, skip_serializing_if = "Option::is_none")]
pub line_number: Option<i32>,
#[doc = "The start offset in the job where the error was found"]
#[serde(rename = "startOffset", default, skip_serializing_if = "Option::is_none")]
pub start_offset: Option<i32>,
#[doc = "The end offset in the job where the error was found."]
#[serde(rename = "endOffset", default, skip_serializing_if = "Option::is_none")]
pub end_offset: Option<i32>,
#[doc = "The recommended resolution for the failure, if any."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub resolution: Option<String>,
#[doc = "The path to any supplemental error files, if any."]
#[serde(rename = "filePath", default, skip_serializing_if = "Option::is_none")]
pub file_path: Option<String>,
#[doc = "The link to MSDN or Azure help for this type of error, if any."]
#[serde(rename = "helpLink", default, skip_serializing_if = "Option::is_none")]
pub help_link: Option<String>,
#[doc = "The internal diagnostic stack trace if the user requesting the job error details has sufficient permissions it will be retrieved, otherwise it will be empty."]
#[serde(rename = "internalDiagnostics", default, skip_serializing_if = "Option::is_none")]
pub internal_diagnostics: Option<String>,
#[doc = "The Data Lake Analytics job error details."]
#[serde(rename = "innerError", default, skip_serializing_if = "Option::is_none")]
pub inner_error: Option<JobInnerError>,
}
impl JobErrorDetails {
pub fn new() -> Self {
Self::default()
}
}
pub mod job_error_details {
use super::*;
#[doc = "The severity level of the failure."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub enum Severity {
Warning,
Error,
Info,
SevereWarning,
Deprecated,
UserWarning,
}
}
#[doc = "List of JobInfo items."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct JobInfoListResult {
#[doc = "The list of JobInfo items."]
#[serde(default, skip_serializing_if = "Vec::is_empty")]
pub value: Vec<JobInformationBasic>,
#[doc = "The link (url) to the next page of results."]
#[serde(rename = "nextLink", default, skip_serializing_if = "Option::is_none")]
pub next_link: Option<String>,
}
impl JobInfoListResult {
pub fn new() -> Self {
Self::default()
}
}
#[doc = "The extended Data Lake Analytics job information properties returned when retrieving a specific job."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct JobInformation {
#[serde(flatten)]
pub job_information_basic: JobInformationBasic,
#[doc = "The error message details for the job, if the job failed."]
#[serde(rename = "errorMessage", default, skip_serializing_if = "Vec::is_empty")]
pub error_message: Vec<JobErrorDetails>,
#[doc = "The job state audit records, indicating when various operations have been performed on this job."]
#[serde(rename = "stateAuditRecords", default, skip_serializing_if = "Vec::is_empty")]
pub state_audit_records: Vec<JobStateAuditRecord>,
#[doc = "The common Data Lake Analytics job properties."]
pub properties: JobProperties,
}
impl JobInformation {
pub fn new(job_information_basic: JobInformationBasic, properties: JobProperties) -> Self {
Self {
job_information_basic,
error_message: Vec::new(),
state_audit_records: Vec::new(),
properties,
}
}
}
#[doc = "The common Data Lake Analytics job information properties."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct JobInformationBasic {
#[doc = "The job's unique identifier (a GUID)."]
#[serde(rename = "jobId", default, skip_serializing_if = "Option::is_none")]
pub job_id: Option<String>,
#[doc = "The friendly name of the job."]
pub name: String,
#[doc = "The job type of the current job (Hive, USql, or Scope (for internal use only))."]
#[serde(rename = "type")]
pub type_: job_information_basic::Type,
#[doc = "The user or account that submitted the job."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub submitter: Option<String>,
#[doc = "The degree of parallelism used for this job."]
#[serde(rename = "degreeOfParallelism", default, skip_serializing_if = "Option::is_none")]
pub degree_of_parallelism: Option<i32>,
#[doc = "the degree of parallelism in percentage used for this job."]
#[serde(rename = "degreeOfParallelismPercent", default, skip_serializing_if = "Option::is_none")]
pub degree_of_parallelism_percent: Option<f64>,
#[doc = "The priority value for the current job. Lower numbers have a higher priority. By default, a job has a priority of 1000. This must be greater than 0."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub priority: Option<i32>,
#[doc = "The time the job was submitted to the service."]
#[serde(rename = "submitTime", default, skip_serializing_if = "Option::is_none")]
pub submit_time: Option<String>,
#[doc = "The start time of the job."]
#[serde(rename = "startTime", default, skip_serializing_if = "Option::is_none")]
pub start_time: Option<String>,
#[doc = "The completion time of the job."]
#[serde(rename = "endTime", default, skip_serializing_if = "Option::is_none")]
pub end_time: Option<String>,
#[doc = "The job state. When the job is in the Ended state, refer to Result and ErrorMessage for details."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub state: Option<job_information_basic::State>,
#[doc = "The result of job execution or the current result of the running job."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub result: Option<job_information_basic::Result>,
#[doc = "The log folder path to use in the following format: adl://<accountName>.azuredatalakestore.net/system/jobservice/jobs/Usql/2016/03/13/17/18/5fe51957-93bc-4de0-8ddc-c5a4753b068b/logs/."]
#[serde(rename = "logFolder", default, skip_serializing_if = "Option::is_none")]
pub log_folder: Option<String>,
#[doc = "The list of log file name patterns to find in the logFolder. '*' is the only matching character allowed. Example format: jobExecution*.log or *mylog*.txt"]
#[serde(rename = "logFilePatterns", default, skip_serializing_if = "Vec::is_empty")]
pub log_file_patterns: Vec<String>,
#[doc = "Job relationship information properties including pipeline information, correlation information, etc."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub related: Option<JobRelationshipProperties>,
#[doc = "The key-value pairs used to add additional metadata to the job information. (Only for use internally with Scope job type.)"]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub tags: Option<serde_json::Value>,
#[doc = "the name of hierarchy queue node this job is assigned to, Null if job has not been assigned yet or the account doesn't have hierarchy queue."]
#[serde(rename = "hierarchyQueueNode", default, skip_serializing_if = "Option::is_none")]
pub hierarchy_queue_node: Option<String>,
}
impl JobInformationBasic {
pub fn new(name: String, type_: job_information_basic::Type) -> Self {
Self {
job_id: None,
name,
type_,
submitter: None,
degree_of_parallelism: None,
degree_of_parallelism_percent: None,
priority: None,
submit_time: None,
start_time: None,
end_time: None,
state: None,
result: None,
log_folder: None,
log_file_patterns: Vec::new(),
related: None,
tags: None,
hierarchy_queue_node: None,
}
}
}
pub mod job_information_basic {
use super::*;
#[doc = "The job type of the current job (Hive, USql, or Scope (for internal use only))."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub enum Type {
USql,
Hive,
Scope,
}
#[doc = "The job state. When the job is in the Ended state, refer to Result and ErrorMessage for details."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub enum State {
Accepted,
Compiling,
Ended,
New,
Queued,
Running,
Scheduling,
Starting,
Paused,
WaitingForCapacity,
Yielded,
Finalizing,
}
#[doc = "The result of job execution or the current result of the running job."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub enum Result {
None,
Succeeded,
Cancelled,
Failed,
}
}
#[doc = "The Data Lake Analytics job error details."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct JobInnerError {
#[doc = "The specific identifier for the type of error encountered in the job."]
#[serde(rename = "errorId", default, skip_serializing_if = "Option::is_none")]
pub error_id: Option<String>,
#[doc = "The severity level of the failure."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub severity: Option<job_inner_error::Severity>,
#[doc = "The ultimate source of the failure (usually either SYSTEM or USER)."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub source: Option<String>,
#[doc = "The user friendly error message for the failure."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub message: Option<String>,
#[doc = "The error message description."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub description: Option<String>,
#[doc = "The details of the error message."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub details: Option<String>,
#[doc = "The diagnostic error code."]
#[serde(rename = "diagnosticCode", default, skip_serializing_if = "Option::is_none")]
pub diagnostic_code: Option<i32>,
#[doc = "The component that failed."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub component: Option<String>,
#[doc = "The recommended resolution for the failure, if any."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub resolution: Option<String>,
#[doc = "The link to MSDN or Azure help for this type of error, if any."]
#[serde(rename = "helpLink", default, skip_serializing_if = "Option::is_none")]
pub help_link: Option<String>,
#[doc = "The internal diagnostic stack trace if the user requesting the job error details has sufficient permissions it will be retrieved, otherwise it will be empty."]
#[serde(rename = "internalDiagnostics", default, skip_serializing_if = "Option::is_none")]
pub internal_diagnostics: Option<String>,
#[doc = "The Data Lake Analytics job error details."]
#[serde(rename = "innerError", default, skip_serializing_if = "Option::is_none")]
pub inner_error: Box<Option<JobInnerError>>,
}
impl JobInnerError {
pub fn new() -> Self {
Self::default()
}
}
pub mod job_inner_error {
use super::*;
#[doc = "The severity level of the failure."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub enum Severity {
Warning,
Error,
Info,
SevereWarning,
Deprecated,
UserWarning,
}
}
#[doc = "Job Pipeline Information, showing the relationship of jobs and recurrences of those jobs in a pipeline."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct JobPipelineInformation {
#[doc = "The job relationship pipeline identifier (a GUID)."]
#[serde(rename = "pipelineId", default, skip_serializing_if = "Option::is_none")]
pub pipeline_id: Option<String>,
#[doc = "The friendly name of the job relationship pipeline, which does not need to be unique."]
#[serde(rename = "pipelineName", default, skip_serializing_if = "Option::is_none")]
pub pipeline_name: Option<String>,
#[doc = "The pipeline uri, unique, links to the originating service for this pipeline."]
#[serde(rename = "pipelineUri", default, skip_serializing_if = "Option::is_none")]
pub pipeline_uri: Option<String>,
#[doc = "The number of jobs in this pipeline that have failed."]
#[serde(rename = "numJobsFailed", default, skip_serializing_if = "Option::is_none")]
pub num_jobs_failed: Option<i32>,
#[doc = "The number of jobs in this pipeline that have been canceled."]
#[serde(rename = "numJobsCanceled", default, skip_serializing_if = "Option::is_none")]
pub num_jobs_canceled: Option<i32>,
#[doc = "The number of jobs in this pipeline that have succeeded."]
#[serde(rename = "numJobsSucceeded", default, skip_serializing_if = "Option::is_none")]
pub num_jobs_succeeded: Option<i32>,
#[doc = "The number of job execution hours that resulted in failed jobs."]
#[serde(rename = "auHoursFailed", default, skip_serializing_if = "Option::is_none")]
pub au_hours_failed: Option<f64>,
#[doc = "The number of job execution hours that resulted in canceled jobs."]
#[serde(rename = "auHoursCanceled", default, skip_serializing_if = "Option::is_none")]
pub au_hours_canceled: Option<f64>,
#[doc = "The number of job execution hours that resulted in successful jobs."]
#[serde(rename = "auHoursSucceeded", default, skip_serializing_if = "Option::is_none")]
pub au_hours_succeeded: Option<f64>,
#[doc = "The last time a job in this pipeline was submitted."]
#[serde(rename = "lastSubmitTime", default, skip_serializing_if = "Option::is_none")]
pub last_submit_time: Option<String>,
#[doc = "The list of recurrence identifiers representing each run of this pipeline."]
#[serde(default, skip_serializing_if = "Vec::is_empty")]
pub runs: Vec<JobPipelineRunInformation>,
#[doc = "The list of recurrence identifiers representing each run of this pipeline."]
#[serde(default, skip_serializing_if = "Vec::is_empty")]
pub recurrences: Vec<String>,
}
impl JobPipelineInformation {
pub fn new() -> Self {
Self::default()
}
}
#[doc = "List of job pipeline information items."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct JobPipelineInformationListResult {
#[doc = "The list of job pipeline information items."]
#[serde(default, skip_serializing_if = "Vec::is_empty")]
pub value: Vec<JobPipelineInformation>,
#[doc = "The link (url) to the next page of results."]
#[serde(rename = "nextLink", default, skip_serializing_if = "Option::is_none")]
pub next_link: Option<String>,
}
impl JobPipelineInformationListResult {
pub fn new() -> Self {
Self::default()
}
}
#[doc = "Run info for a specific job pipeline."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct JobPipelineRunInformation {
#[doc = "The run identifier of an instance of pipeline executions (a GUID)."]
#[serde(rename = "runId", default, skip_serializing_if = "Option::is_none")]
pub run_id: Option<String>,
#[doc = "The time this instance was last submitted."]
#[serde(rename = "lastSubmitTime", default, skip_serializing_if = "Option::is_none")]
pub last_submit_time: Option<String>,
}
impl JobPipelineRunInformation {
pub fn new() -> Self {
Self::default()
}
}
#[doc = "The common Data Lake Analytics job properties."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct JobProperties {
#[doc = "The runtime version of the Data Lake Analytics engine to use for the specific type of job being run."]
#[serde(rename = "runtimeVersion", default, skip_serializing_if = "Option::is_none")]
pub runtime_version: Option<String>,
#[doc = "The script to run. Please note that the maximum script size is 3 MB."]
pub script: String,
#[doc = "The job type of the current job (Hive, USql, or Scope (for internal use only))."]
#[serde(rename = "type")]
pub type_: String,
}
impl JobProperties {
pub fn new(script: String, type_: String) -> Self {
Self {
runtime_version: None,
script,
type_,
}
}
}
#[doc = "Recurrence job information for a specific recurrence."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct JobRecurrenceInformation {
#[doc = "The recurrence identifier (a GUID), unique per activity/script, regardless of iterations. This is something to link different occurrences of the same job together."]
#[serde(rename = "recurrenceId", default, skip_serializing_if = "Option::is_none")]
pub recurrence_id: Option<String>,
#[doc = "The recurrence name, user friendly name for the correlation between jobs."]
#[serde(rename = "recurrenceName", default, skip_serializing_if = "Option::is_none")]
pub recurrence_name: Option<String>,
#[doc = "The number of jobs in this recurrence that have failed."]
#[serde(rename = "numJobsFailed", default, skip_serializing_if = "Option::is_none")]
pub num_jobs_failed: Option<i32>,
#[doc = "The number of jobs in this recurrence that have been canceled."]
#[serde(rename = "numJobsCanceled", default, skip_serializing_if = "Option::is_none")]
pub num_jobs_canceled: Option<i32>,
#[doc = "The number of jobs in this recurrence that have succeeded."]
#[serde(rename = "numJobsSucceeded", default, skip_serializing_if = "Option::is_none")]
pub num_jobs_succeeded: Option<i32>,
#[doc = "The number of job execution hours that resulted in failed jobs."]
#[serde(rename = "auHoursFailed", default, skip_serializing_if = "Option::is_none")]
pub au_hours_failed: Option<f64>,
#[doc = "The number of job execution hours that resulted in canceled jobs."]
#[serde(rename = "auHoursCanceled", default, skip_serializing_if = "Option::is_none")]
pub au_hours_canceled: Option<f64>,
#[doc = "The number of job execution hours that resulted in successful jobs."]
#[serde(rename = "auHoursSucceeded", default, skip_serializing_if = "Option::is_none")]
pub au_hours_succeeded: Option<f64>,
#[doc = "The last time a job in this recurrence was submitted."]
#[serde(rename = "lastSubmitTime", default, skip_serializing_if = "Option::is_none")]
pub last_submit_time: Option<String>,
}
impl JobRecurrenceInformation {
pub fn new() -> Self {
Self::default()
}
}
#[doc = "List of job recurrence information items."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct JobRecurrenceInformationListResult {
#[doc = "The list of job recurrence information items."]
#[serde(default, skip_serializing_if = "Vec::is_empty")]
pub value: Vec<JobRecurrenceInformation>,
#[doc = "The link (url) to the next page of results."]
#[serde(rename = "nextLink", default, skip_serializing_if = "Option::is_none")]
pub next_link: Option<String>,
}
impl JobRecurrenceInformationListResult {
pub fn new() -> Self {
Self::default()
}
}
#[doc = "Job relationship information properties including pipeline information, correlation information, etc."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct JobRelationshipProperties {
#[doc = "The job relationship pipeline identifier (a GUID)."]
#[serde(rename = "pipelineId", default, skip_serializing_if = "Option::is_none")]
pub pipeline_id: Option<String>,
#[doc = "The friendly name of the job relationship pipeline, which does not need to be unique."]
#[serde(rename = "pipelineName", default, skip_serializing_if = "Option::is_none")]
pub pipeline_name: Option<String>,
#[doc = "The pipeline uri, unique, links to the originating service for this pipeline."]
#[serde(rename = "pipelineUri", default, skip_serializing_if = "Option::is_none")]
pub pipeline_uri: Option<String>,
#[doc = "The run identifier (a GUID), unique identifier of the iteration of this pipeline."]
#[serde(rename = "runId", default, skip_serializing_if = "Option::is_none")]
pub run_id: Option<String>,
#[doc = "The recurrence identifier (a GUID), unique per activity/script, regardless of iterations. This is something to link different occurrences of the same job together."]
#[serde(rename = "recurrenceId")]
pub recurrence_id: String,
#[doc = "The recurrence name, user friendly name for the correlation between jobs."]
#[serde(rename = "recurrenceName", default, skip_serializing_if = "Option::is_none")]
pub recurrence_name: Option<String>,
}
impl JobRelationshipProperties {
pub fn new(recurrence_id: String) -> Self {
Self {
pipeline_id: None,
pipeline_name: None,
pipeline_uri: None,
run_id: None,
recurrence_id,
recurrence_name: None,
}
}
}
#[doc = "The Data Lake Analytics job resources."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct JobResource {
#[doc = "The name of the resource."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[doc = "The path to the resource."]
#[serde(rename = "resourcePath", default, skip_serializing_if = "Option::is_none")]
pub resource_path: Option<String>,
#[doc = "The job resource type."]
#[serde(rename = "type", default, skip_serializing_if = "Option::is_none")]
pub type_: Option<job_resource::Type>,
}
impl JobResource {
pub fn new() -> Self {
Self::default()
}
}
pub mod job_resource {
use super::*;
#[doc = "The job resource type."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub enum Type {
VertexResource,
JobManagerResource,
StatisticsResource,
VertexResourceInUserFolder,
JobManagerResourceInUserFolder,
StatisticsResourceInUserFolder,
}
}
#[doc = "The Data Lake Analytics job state audit records for tracking the lifecycle of a job."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct JobStateAuditRecord {
#[doc = "The new state the job is in."]
#[serde(rename = "newState", default, skip_serializing_if = "Option::is_none")]
pub new_state: Option<String>,
#[doc = "The time stamp that the state change took place."]
#[serde(rename = "timeStamp", default, skip_serializing_if = "Option::is_none")]
pub time_stamp: Option<String>,
#[doc = "The user who requests the change."]
#[serde(rename = "requestedByUser", default, skip_serializing_if = "Option::is_none")]
pub requested_by_user: Option<String>,
#[doc = "The details of the audit log."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub details: Option<String>,
}
impl JobStateAuditRecord {
pub fn new() -> Self {
Self::default()
}
}
#[doc = "The Data Lake Analytics job execution statistics."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct JobStatistics {
#[doc = "The last update time for the statistics."]
#[serde(rename = "lastUpdateTimeUtc", default, skip_serializing_if = "Option::is_none")]
pub last_update_time_utc: Option<String>,
#[doc = "The job finalizing start time."]
#[serde(rename = "finalizingTimeUtc", default, skip_serializing_if = "Option::is_none")]
pub finalizing_time_utc: Option<String>,
#[doc = "The list of stages for the job."]
#[serde(default, skip_serializing_if = "Vec::is_empty")]
pub stages: Vec<JobStatisticsVertexStage>,
}
impl JobStatistics {
pub fn new() -> Self {
Self::default()
}
}
#[doc = "The detailed information for a vertex."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct JobStatisticsVertex {
#[doc = "The name of the vertex."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[doc = "The id of the vertex."]
#[serde(rename = "vertexId", default, skip_serializing_if = "Option::is_none")]
pub vertex_id: Option<String>,
#[doc = "The amount of execution time of the vertex."]
#[serde(rename = "executionTime", default, skip_serializing_if = "Option::is_none")]
pub execution_time: Option<String>,
#[doc = "The amount of data read of the vertex, in bytes."]
#[serde(rename = "dataRead", default, skip_serializing_if = "Option::is_none")]
pub data_read: Option<i64>,
#[doc = "The amount of peak memory usage of the vertex, in bytes."]
#[serde(rename = "peakMemUsage", default, skip_serializing_if = "Option::is_none")]
pub peak_mem_usage: Option<i64>,
}
impl JobStatisticsVertex {
pub fn new() -> Self {
Self::default()
}
}
#[doc = "The Data Lake Analytics job statistics vertex stage information."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct JobStatisticsVertexStage {
#[doc = "The amount of data read, in bytes."]
#[serde(rename = "dataRead", default, skip_serializing_if = "Option::is_none")]
pub data_read: Option<i64>,
#[doc = "The amount of data read across multiple pods, in bytes."]
#[serde(rename = "dataReadCrossPod", default, skip_serializing_if = "Option::is_none")]
pub data_read_cross_pod: Option<i64>,
#[doc = "The amount of data read in one pod, in bytes."]
#[serde(rename = "dataReadIntraPod", default, skip_serializing_if = "Option::is_none")]
pub data_read_intra_pod: Option<i64>,
#[doc = "The amount of data remaining to be read, in bytes."]
#[serde(rename = "dataToRead", default, skip_serializing_if = "Option::is_none")]
pub data_to_read: Option<i64>,
#[doc = "The amount of data written, in bytes."]
#[serde(rename = "dataWritten", default, skip_serializing_if = "Option::is_none")]
pub data_written: Option<i64>,
#[doc = "The number of duplicates that were discarded."]
#[serde(rename = "duplicateDiscardCount", default, skip_serializing_if = "Option::is_none")]
pub duplicate_discard_count: Option<i32>,
#[doc = "The number of failures that occurred in this stage."]
#[serde(rename = "failedCount", default, skip_serializing_if = "Option::is_none")]
pub failed_count: Option<i32>,
#[doc = "The maximum amount of data read in a single vertex, in bytes."]
#[serde(rename = "maxVertexDataRead", default, skip_serializing_if = "Option::is_none")]
pub max_vertex_data_read: Option<i64>,
#[doc = "The minimum amount of data read in a single vertex, in bytes."]
#[serde(rename = "minVertexDataRead", default, skip_serializing_if = "Option::is_none")]
pub min_vertex_data_read: Option<i64>,
#[doc = "The number of read failures in this stage."]
#[serde(rename = "readFailureCount", default, skip_serializing_if = "Option::is_none")]
pub read_failure_count: Option<i32>,
#[doc = "The number of vertices that were revoked during this stage."]
#[serde(rename = "revocationCount", default, skip_serializing_if = "Option::is_none")]
pub revocation_count: Option<i32>,
#[doc = "The number of currently running vertices in this stage."]
#[serde(rename = "runningCount", default, skip_serializing_if = "Option::is_none")]
pub running_count: Option<i32>,
#[doc = "The number of currently scheduled vertices in this stage."]
#[serde(rename = "scheduledCount", default, skip_serializing_if = "Option::is_none")]
pub scheduled_count: Option<i32>,
#[doc = "The name of this stage in job execution."]
#[serde(rename = "stageName", default, skip_serializing_if = "Option::is_none")]
pub stage_name: Option<String>,
#[doc = "The number of vertices that succeeded in this stage."]
#[serde(rename = "succeededCount", default, skip_serializing_if = "Option::is_none")]
pub succeeded_count: Option<i32>,
#[doc = "The amount of temporary data written, in bytes."]
#[serde(rename = "tempDataWritten", default, skip_serializing_if = "Option::is_none")]
pub temp_data_written: Option<i64>,
#[doc = "The total vertex count for this stage."]
#[serde(rename = "totalCount", default, skip_serializing_if = "Option::is_none")]
pub total_count: Option<i32>,
#[doc = "The amount of time that failed vertices took up in this stage."]
#[serde(rename = "totalFailedTime", default, skip_serializing_if = "Option::is_none")]
pub total_failed_time: Option<String>,
#[doc = "The current progress of this stage, as a percentage."]
#[serde(rename = "totalProgress", default, skip_serializing_if = "Option::is_none")]
pub total_progress: Option<i32>,
#[doc = "The amount of time all successful vertices took in this stage."]
#[serde(rename = "totalSucceededTime", default, skip_serializing_if = "Option::is_none")]
pub total_succeeded_time: Option<String>,
#[doc = "The sum of the peak memory usage of all the vertices in the stage, in bytes."]
#[serde(rename = "totalPeakMemUsage", default, skip_serializing_if = "Option::is_none")]
pub total_peak_mem_usage: Option<i64>,
#[doc = "The sum of the total execution time of all the vertices in the stage."]
#[serde(rename = "totalExecutionTime", default, skip_serializing_if = "Option::is_none")]
pub total_execution_time: Option<String>,
#[doc = "The detailed information for a vertex."]
#[serde(rename = "maxDataReadVertex", default, skip_serializing_if = "Option::is_none")]
pub max_data_read_vertex: Option<JobStatisticsVertex>,
#[doc = "The detailed information for a vertex."]
#[serde(rename = "maxExecutionTimeVertex", default, skip_serializing_if = "Option::is_none")]
pub max_execution_time_vertex: Option<JobStatisticsVertex>,
#[doc = "The detailed information for a vertex."]
#[serde(rename = "maxPeakMemUsageVertex", default, skip_serializing_if = "Option::is_none")]
pub max_peak_mem_usage_vertex: Option<JobStatisticsVertex>,
#[doc = "The estimated vertex CPU core count."]
#[serde(rename = "estimatedVertexCpuCoreCount", default, skip_serializing_if = "Option::is_none")]
pub estimated_vertex_cpu_core_count: Option<i32>,
#[doc = "The estimated vertex peak CPU core count."]
#[serde(rename = "estimatedVertexPeakCpuCoreCount", default, skip_serializing_if = "Option::is_none")]
pub estimated_vertex_peak_cpu_core_count: Option<i32>,
#[doc = "The estimated vertex memory size, in bytes."]
#[serde(rename = "estimatedVertexMemSize", default, skip_serializing_if = "Option::is_none")]
pub estimated_vertex_mem_size: Option<i64>,
#[doc = "The statistics information for resource usage."]
#[serde(rename = "allocatedContainerCpuCoreCount", default, skip_serializing_if = "Option::is_none")]
pub allocated_container_cpu_core_count: Option<ResourceUsageStatistics>,
#[doc = "The statistics information for resource usage."]
#[serde(rename = "allocatedContainerMemSize", default, skip_serializing_if = "Option::is_none")]
pub allocated_container_mem_size: Option<ResourceUsageStatistics>,
#[doc = "The statistics information for resource usage."]
#[serde(rename = "usedVertexCpuCoreCount", default, skip_serializing_if = "Option::is_none")]
pub used_vertex_cpu_core_count: Option<ResourceUsageStatistics>,
#[doc = "The statistics information for resource usage."]
#[serde(rename = "usedVertexPeakMemSize", default, skip_serializing_if = "Option::is_none")]
pub used_vertex_peak_mem_size: Option<ResourceUsageStatistics>,
}
impl JobStatisticsVertexStage {
pub fn new() -> Self {
Self::default()
}
}
#[doc = "The statistics information for resource usage."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct ResourceUsageStatistics {
#[doc = "The average value."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub average: Option<f64>,
#[doc = "The minimum value."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub minimum: Option<i64>,
#[doc = "The maximum value."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub maximum: Option<i64>,
}
impl ResourceUsageStatistics {
pub fn new() -> Self {
Self::default()
}
}
#[doc = "Scope job properties used when submitting and retrieving Scope jobs. (Only for use internally with Scope job type.)"]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct ScopeJobProperties {
#[serde(flatten)]
pub job_properties: JobProperties,
#[doc = "The list of resources that are required by the job."]
#[serde(default, skip_serializing_if = "Vec::is_empty")]
pub resources: Vec<ScopeJobResource>,
#[doc = "The algebra file path after the job has completed."]
#[serde(rename = "userAlgebraPath", default, skip_serializing_if = "Option::is_none")]
pub user_algebra_path: Option<String>,
#[doc = "The list of email addresses, separated by semi-colons, to notify when the job reaches a terminal state."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub notifier: Option<String>,
#[doc = "The total time this job spent compiling. This value should not be set by the user and will be ignored if it is."]
#[serde(rename = "totalCompilationTime", default, skip_serializing_if = "Option::is_none")]
pub total_compilation_time: Option<String>,
#[doc = "The total time this job spent queued. This value should not be set by the user and will be ignored if it is."]
#[serde(rename = "totalQueuedTime", default, skip_serializing_if = "Option::is_none")]
pub total_queued_time: Option<String>,
#[doc = "The total time this job spent executing. This value should not be set by the user and will be ignored if it is."]
#[serde(rename = "totalRunningTime", default, skip_serializing_if = "Option::is_none")]
pub total_running_time: Option<String>,
#[doc = "The total time this job spent paused. This value should not be set by the user and will be ignored if it is."]
#[serde(rename = "totalPausedTime", default, skip_serializing_if = "Option::is_none")]
pub total_paused_time: Option<String>,
#[doc = "The ID used to identify the job manager coordinating job execution. This value should not be set by the user and will be ignored if it is."]
#[serde(rename = "rootProcessNodeId", default, skip_serializing_if = "Option::is_none")]
pub root_process_node_id: Option<String>,
#[doc = "The ID used to identify the yarn application executing the job. This value should not be set by the user and will be ignored if it is."]
#[serde(rename = "yarnApplicationId", default, skip_serializing_if = "Option::is_none")]
pub yarn_application_id: Option<String>,
}
impl ScopeJobProperties {
pub fn new(job_properties: JobProperties) -> Self {
Self {
job_properties,
resources: Vec::new(),
user_algebra_path: None,
notifier: None,
total_compilation_time: None,
total_queued_time: None,
total_running_time: None,
total_paused_time: None,
root_process_node_id: None,
yarn_application_id: None,
}
}
}
#[doc = "The Scope job resources. (Only for use internally with Scope job type.)"]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct ScopeJobResource {
#[doc = "The name of the resource."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub name: Option<String>,
#[doc = "The path to the resource."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub path: Option<String>,
}
impl ScopeJobResource {
pub fn new() -> Self {
Self::default()
}
}
#[doc = "U-SQL job properties used when retrieving U-SQL jobs."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub struct USqlJobProperties {
#[serde(flatten)]
pub job_properties: JobProperties,
#[doc = "The list of resources that are required by the job."]
#[serde(default, skip_serializing_if = "Vec::is_empty")]
pub resources: Vec<JobResource>,
#[doc = "The Data Lake Analytics job execution statistics."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub statistics: Option<JobStatistics>,
#[doc = "A Data Lake Analytics job data path item."]
#[serde(rename = "debugData", default, skip_serializing_if = "Option::is_none")]
pub debug_data: Option<JobDataPath>,
#[doc = "The diagnostics for the job."]
#[serde(default, skip_serializing_if = "Vec::is_empty")]
pub diagnostics: Vec<Diagnostics>,
#[doc = "The algebra file path after the job has completed."]
#[serde(rename = "algebraFilePath", default, skip_serializing_if = "Option::is_none")]
pub algebra_file_path: Option<String>,
#[doc = "The total time this job spent compiling. This value should not be set by the user and will be ignored if it is."]
#[serde(rename = "totalCompilationTime", default, skip_serializing_if = "Option::is_none")]
pub total_compilation_time: Option<String>,
#[doc = "The total time this job spent queued. This value should not be set by the user and will be ignored if it is."]
#[serde(rename = "totalQueuedTime", default, skip_serializing_if = "Option::is_none")]
pub total_queued_time: Option<String>,
#[doc = "The total time this job spent executing. This value should not be set by the user and will be ignored if it is."]
#[serde(rename = "totalRunningTime", default, skip_serializing_if = "Option::is_none")]
pub total_running_time: Option<String>,
#[doc = "The total time this job spent paused. This value should not be set by the user and will be ignored if it is."]
#[serde(rename = "totalPausedTime", default, skip_serializing_if = "Option::is_none")]
pub total_paused_time: Option<String>,
#[doc = "The ID used to identify the job manager coordinating job execution. This value should not be set by the user and will be ignored if it is."]
#[serde(rename = "rootProcessNodeId", default, skip_serializing_if = "Option::is_none")]
pub root_process_node_id: Option<String>,
#[doc = "The ID used to identify the yarn application executing the job. This value should not be set by the user and will be ignored if it is."]
#[serde(rename = "yarnApplicationId", default, skip_serializing_if = "Option::is_none")]
pub yarn_application_id: Option<String>,
#[doc = "The timestamp (in ticks) for the yarn application executing the job. This value should not be set by the user and will be ignored if it is."]
#[serde(rename = "yarnApplicationTimeStamp", default, skip_serializing_if = "Option::is_none")]
pub yarn_application_time_stamp: Option<i64>,
#[doc = "The specific compilation mode for the job used during execution. If this is not specified during submission, the server will determine the optimal compilation mode."]
#[serde(rename = "compileMode", default, skip_serializing_if = "Option::is_none")]
pub compile_mode: Option<u_sql_job_properties::CompileMode>,
}
impl USqlJobProperties {
pub fn new(job_properties: JobProperties) -> Self {
Self {
job_properties,
resources: Vec::new(),
statistics: None,
debug_data: None,
diagnostics: Vec::new(),
algebra_file_path: None,
total_compilation_time: None,
total_queued_time: None,
total_running_time: None,
total_paused_time: None,
root_process_node_id: None,
yarn_application_id: None,
yarn_application_time_stamp: None,
compile_mode: None,
}
}
}
pub mod u_sql_job_properties {
use super::*;
#[doc = "The specific compilation mode for the job used during execution. If this is not specified during submission, the server will determine the optimal compilation mode."]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize)]
pub enum CompileMode {
Semantic,
Full,
SingleBox,
}
}
#[doc = "The parameters that can be used to update existing Data Lake Analytics job information properties. (Only for use internally with Scope job type.)"]
#[derive(Clone, Debug, PartialEq, Serialize, Deserialize, Default)]
pub struct UpdateJobParameters {
#[doc = "The degree of parallelism used for this job."]
#[serde(rename = "degreeOfParallelism", default, skip_serializing_if = "Option::is_none")]
pub degree_of_parallelism: Option<i32>,
#[doc = "the degree of parallelism in percentage used for this job."]
#[serde(rename = "degreeOfParallelismPercent", default, skip_serializing_if = "Option::is_none")]
pub degree_of_parallelism_percent: Option<f64>,
#[doc = "The priority value for the current job. Lower numbers have a higher priority. By default, a job has a priority of 1000. This must be greater than 0."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub priority: Option<i32>,
#[doc = "The key-value pairs used to add additional metadata to the job information."]
#[serde(default, skip_serializing_if = "Option::is_none")]
pub tags: Option<serde_json::Value>,
}
impl UpdateJobParameters {
pub fn new() -> Self {
Self::default()
}
}