opensearch_client/ml/
task.rs1use crate::common;
12use serde::{Deserialize, Serialize};
13
14
15
16
17#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
18pub struct Task { #[serde(rename = "task_type", default, skip_serializing_if = "Option::is_none")]
20 pub task_type: Option<String>,
21 #[serde(rename = "model_id", default, skip_serializing_if = "Option::is_none")]
22 pub model_id: Option<String>,
23 #[serde(rename = "error", default, skip_serializing_if = "Option::is_none")]
24 pub error: Option<String>,
25 #[serde(rename = "state")]
26 pub state: String,
27 #[serde(rename = "last_update_time", default, skip_serializing_if = "Option::is_none")]
28 pub last_update_time: Option<u32>, #[serde(rename = "function_name", default, skip_serializing_if = "Option::is_none")]
30 pub function_name: Option<String>,
31 #[serde(rename = "is_async", default, skip_serializing_if = "Option::is_none")]
32 pub is_async: Option<bool>,
33 #[serde(rename = "worker_node", default, skip_serializing_if = "Option::is_none")]
34 pub worker_node: Option<Vec<common::NodeIds>>,
35 #[serde(rename = "task_id", default, skip_serializing_if = "Option::is_none")]
36 pub task_id: Option<String>,
37 #[serde(rename = "create_time", default, skip_serializing_if = "Option::is_none")]
38 pub create_time: Option<u32>,
39}
40
41impl Task {
42
43 pub fn new(state: String) -> Task {
44 Task {
45 task_type: None,
46 model_id: None,
47 error: None,
48 state,
49 last_update_time: None,
50 function_name: None,
51 is_async: None,
52 worker_node: None,
53 task_id: None,
54 create_time: None,
55 }
56 }
57}