Struct PipelineTaskDetail 

#[non_exhaustive]
pub struct PipelineTaskDetail {

    pub task_id: i64,
    pub parent_task_id: i64,
    pub task_name: String,
    pub create_time: Option<Timestamp>,
    pub start_time: Option<Timestamp>,
    pub end_time: Option<Timestamp>,
    pub executor_detail: Option<PipelineTaskExecutorDetail>,
    pub state: State,
    pub execution: Option<Execution>,
    pub error: Option<Status>,
    pub pipeline_task_status: Vec<PipelineTaskStatus>,
    pub inputs: HashMap<String, ArtifactList>,
    pub outputs: HashMap<String, ArtifactList>,
    pub task_unique_name: String,
    /* private fields */
}

Available on crate features pipeline-service or schedule-service only.

The runtime detail of a task execution.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

task_id: i64

Output only. The system generated ID of the task.

parent_task_id: i64

Output only. The id of the parent task if the task is within a component scope. Empty if the task is at the root level.

task_name: String

Output only. The user specified name of the task that is defined in pipeline_spec.

create_time: Option<Timestamp>

Output only. Task create time.

start_time: Option<Timestamp>

Output only. Task start time.

end_time: Option<Timestamp>

Output only. Task end time.

executor_detail: Option<PipelineTaskExecutorDetail>

Output only. The detailed execution info.

state: State

Output only. State of the task.

execution: Option<Execution>

Output only. The execution metadata of the task.

error: Option<Status>

Output only. The error that occurred during task execution. Only populated when the task’s state is FAILED or CANCELLED.

pipeline_task_status: Vec<PipelineTaskStatus>

Output only. A list of task status. This field keeps a record of task status evolving over time.

inputs: HashMap<String, ArtifactList>

Output only. The runtime input artifacts of the task.

outputs: HashMap<String, ArtifactList>

Output only. The runtime output artifacts of the task.

task_unique_name: String

Output only. The unique name of a task. This field is used by rerun pipeline job. Console UI and Vertex AI SDK will support triggering pipeline job reruns. The name is constructed by concatenating all the parent tasks name with the task name. For example, if a task named “child_task” has a parent task named “parent_task_1” and parent task 1 has a parent task named “parent_task_2”, the task unique name will be “parent_task_2.parent_task_1.child_task”.

Implementations

impl PipelineTaskDetail

pub fn new() -> Self

pub fn set_task_id<T: Into<i64>>(self, v: T) -> Self

Sets the value of task_id.

Example

let x = PipelineTaskDetail::new().set_task_id(42);

pub fn set_parent_task_id<T: Into<i64>>(self, v: T) -> Self

Sets the value of parent_task_id.

Example

let x = PipelineTaskDetail::new().set_parent_task_id(42);

pub fn set_task_name<T: Into<String>>(self, v: T) -> Self

Sets the value of task_name.

Example

let x = PipelineTaskDetail::new().set_task_name("example");

pub fn set_create_time<T>(self, v: T) -> Self

where T: Into<Timestamp>,

Sets the value of create_time.

Example

use wkt::Timestamp;
let x = PipelineTaskDetail::new().set_create_time(Timestamp::default()/* use setters */);

pub fn set_or_clear_create_time<T>(self, v: Option<T>) -> Self

where T: Into<Timestamp>,

Sets or clears the value of create_time.

Example

use wkt::Timestamp;
let x = PipelineTaskDetail::new().set_or_clear_create_time(Some(Timestamp::default()/* use setters */));
let x = PipelineTaskDetail::new().set_or_clear_create_time(None::<Timestamp>);

pub fn set_start_time<T>(self, v: T) -> Self

where T: Into<Timestamp>,

Sets the value of start_time.

Example

use wkt::Timestamp;
let x = PipelineTaskDetail::new().set_start_time(Timestamp::default()/* use setters */);

pub fn set_or_clear_start_time<T>(self, v: Option<T>) -> Self

where T: Into<Timestamp>,

Sets or clears the value of start_time.

Example

use wkt::Timestamp;
let x = PipelineTaskDetail::new().set_or_clear_start_time(Some(Timestamp::default()/* use setters */));
let x = PipelineTaskDetail::new().set_or_clear_start_time(None::<Timestamp>);

pub fn set_end_time<T>(self, v: T) -> Self

where T: Into<Timestamp>,

Sets the value of end_time.

Example

use wkt::Timestamp;
let x = PipelineTaskDetail::new().set_end_time(Timestamp::default()/* use setters */);

pub fn set_or_clear_end_time<T>(self, v: Option<T>) -> Self

where T: Into<Timestamp>,

Sets or clears the value of end_time.

Example

use wkt::Timestamp;
let x = PipelineTaskDetail::new().set_or_clear_end_time(Some(Timestamp::default()/* use setters */));
let x = PipelineTaskDetail::new().set_or_clear_end_time(None::<Timestamp>);

pub fn set_executor_detail<T>(self, v: T) -> Self

where T: Into<PipelineTaskExecutorDetail>,

Sets the value of executor_detail.

Example

use google_cloud_aiplatform_v1::model::PipelineTaskExecutorDetail;
let x = PipelineTaskDetail::new().set_executor_detail(PipelineTaskExecutorDetail::default()/* use setters */);

pub fn set_or_clear_executor_detail<T>(self, v: Option<T>) -> Self

where T: Into<PipelineTaskExecutorDetail>,

Sets or clears the value of executor_detail.

Example

use google_cloud_aiplatform_v1::model::PipelineTaskExecutorDetail;
let x = PipelineTaskDetail::new().set_or_clear_executor_detail(Some(PipelineTaskExecutorDetail::default()/* use setters */));
let x = PipelineTaskDetail::new().set_or_clear_executor_detail(None::<PipelineTaskExecutorDetail>);

pub fn set_state<T: Into<State>>(self, v: T) -> Self

Sets the value of state.

Example

use google_cloud_aiplatform_v1::model::pipeline_task_detail::State;
let x0 = PipelineTaskDetail::new().set_state(State::Pending);
let x1 = PipelineTaskDetail::new().set_state(State::Running);
let x2 = PipelineTaskDetail::new().set_state(State::Succeeded);

pub fn set_execution<T>(self, v: T) -> Self

where T: Into<Execution>,

Sets the value of execution.

Example

use google_cloud_aiplatform_v1::model::Execution;
let x = PipelineTaskDetail::new().set_execution(Execution::default()/* use setters */);

pub fn set_or_clear_execution<T>(self, v: Option<T>) -> Self

where T: Into<Execution>,

Sets or clears the value of execution.

Example

use google_cloud_aiplatform_v1::model::Execution;
let x = PipelineTaskDetail::new().set_or_clear_execution(Some(Execution::default()/* use setters */));
let x = PipelineTaskDetail::new().set_or_clear_execution(None::<Execution>);

pub fn set_error<T>(self, v: T) -> Self

where T: Into<Status>,

Sets the value of error.

Example

use rpc::model::Status;
let x = PipelineTaskDetail::new().set_error(Status::default()/* use setters */);

pub fn set_or_clear_error<T>(self, v: Option<T>) -> Self

where T: Into<Status>,

Sets or clears the value of error.

Example

use rpc::model::Status;
let x = PipelineTaskDetail::new().set_or_clear_error(Some(Status::default()/* use setters */));
let x = PipelineTaskDetail::new().set_or_clear_error(None::<Status>);

pub fn set_pipeline_task_status<T, V>(self, v: T) -> Self

where T: IntoIterator<Item = V>, V: Into<PipelineTaskStatus>,

Sets the value of pipeline_task_status.

Example

use google_cloud_aiplatform_v1::model::pipeline_task_detail::PipelineTaskStatus;
let x = PipelineTaskDetail::new()
    .set_pipeline_task_status([
        PipelineTaskStatus::default()/* use setters */,
        PipelineTaskStatus::default()/* use (different) setters */,
    ]);

pub fn set_inputs<T, K, V>(self, v: T) -> Self

where T: IntoIterator<Item = (K, V)>, K: Into<String>, V: Into<ArtifactList>,

Sets the value of inputs.

Example

use google_cloud_aiplatform_v1::model::pipeline_task_detail::ArtifactList;
let x = PipelineTaskDetail::new().set_inputs([
    ("key0", ArtifactList::default()/* use setters */),
    ("key1", ArtifactList::default()/* use (different) setters */),
]);

pub fn set_outputs<T, K, V>(self, v: T) -> Self

where T: IntoIterator<Item = (K, V)>, K: Into<String>, V: Into<ArtifactList>,

Sets the value of outputs.

Example

use google_cloud_aiplatform_v1::model::pipeline_task_detail::ArtifactList;
let x = PipelineTaskDetail::new().set_outputs([
    ("key0", ArtifactList::default()/* use setters */),
    ("key1", ArtifactList::default()/* use (different) setters */),
]);

pub fn set_task_unique_name<T: Into<String>>(self, v: T) -> Self

Sets the value of task_unique_name.

Example

let x = PipelineTaskDetail::new().set_task_unique_name("example");

Trait Implementations

impl Clone for PipelineTaskDetail

fn clone(&self) -> PipelineTaskDetail

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PipelineTaskDetail

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PipelineTaskDetail

fn default() -> PipelineTaskDetail

Returns the “default value” for a type.

impl Message for PipelineTaskDetail

fn typename() -> &'static str

The typename of this message.

impl PartialEq for PipelineTaskDetail

fn eq(&self, other: &PipelineTaskDetail) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for PipelineTaskDetail