hatchet-sdk 0.2.8

This is an unofficial Rust SDK for Hatchet, a distributed, fault-tolerant task queue.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138

/*
 * Hatchet API
 *
 * The Hatchet API
 *
 * The version of the OpenAPI document: 1.0.0
 *
 * Generated by: https://openapi-generator.tech
 */

use crate::clients::rest::models;
use serde::{Deserialize, Serialize};

#[derive(Clone, Default, Debug, PartialEq, Serialize, Deserialize)]
pub struct StepRunGet200Response {
    #[serde(rename = "metadata")]
    pub metadata: Box<models::V1TaskGet200ResponseMetadata>,
    #[serde(rename = "tenantId")]
    pub tenant_id: String,
    #[serde(rename = "jobRunId")]
    pub job_run_id: String,
    #[serde(rename = "jobRun", skip_serializing_if = "Option::is_none")]
    pub job_run: Option<Box<models::WorkflowRunCreate200ResponseJobRunsInner>>,
    #[serde(rename = "stepId")]
    pub step_id: String,
    #[serde(rename = "step", skip_serializing_if = "Option::is_none")]
    pub step: Option<Box<models::WorkflowList200ResponseRowsInnerJobsInnerStepsInner>>,
    #[serde(
        rename = "childWorkflowsCount",
        skip_serializing_if = "Option::is_none"
    )]
    pub child_workflows_count: Option<i32>,
    #[serde(rename = "parents", skip_serializing_if = "Option::is_none")]
    pub parents: Option<Vec<String>>,
    #[serde(rename = "childWorkflowRuns", skip_serializing_if = "Option::is_none")]
    pub child_workflow_runs: Option<Vec<String>>,
    #[serde(rename = "workerId", skip_serializing_if = "Option::is_none")]
    pub worker_id: Option<String>,
    #[serde(rename = "input", skip_serializing_if = "Option::is_none")]
    pub input: Option<String>,
    #[serde(rename = "output", skip_serializing_if = "Option::is_none")]
    pub output: Option<String>,
    #[serde(rename = "status")]
    pub status: Status,
    #[serde(rename = "requeueAfter", skip_serializing_if = "Option::is_none")]
    pub requeue_after: Option<String>,
    #[serde(rename = "result", skip_serializing_if = "Option::is_none")]
    pub result: Option<serde_json::Value>,
    #[serde(rename = "error", skip_serializing_if = "Option::is_none")]
    pub error: Option<String>,
    #[serde(rename = "startedAt", skip_serializing_if = "Option::is_none")]
    pub started_at: Option<String>,
    #[serde(rename = "startedAtEpoch", skip_serializing_if = "Option::is_none")]
    pub started_at_epoch: Option<i32>,
    #[serde(rename = "finishedAt", skip_serializing_if = "Option::is_none")]
    pub finished_at: Option<String>,
    #[serde(rename = "finishedAtEpoch", skip_serializing_if = "Option::is_none")]
    pub finished_at_epoch: Option<i32>,
    #[serde(rename = "timeoutAt", skip_serializing_if = "Option::is_none")]
    pub timeout_at: Option<String>,
    #[serde(rename = "timeoutAtEpoch", skip_serializing_if = "Option::is_none")]
    pub timeout_at_epoch: Option<i32>,
    #[serde(rename = "cancelledAt", skip_serializing_if = "Option::is_none")]
    pub cancelled_at: Option<String>,
    #[serde(rename = "cancelledAtEpoch", skip_serializing_if = "Option::is_none")]
    pub cancelled_at_epoch: Option<i32>,
    #[serde(rename = "cancelledReason", skip_serializing_if = "Option::is_none")]
    pub cancelled_reason: Option<String>,
    #[serde(rename = "cancelledError", skip_serializing_if = "Option::is_none")]
    pub cancelled_error: Option<String>,
}

impl StepRunGet200Response {
    pub fn new(
        metadata: models::V1TaskGet200ResponseMetadata,
        tenant_id: String,
        job_run_id: String,
        step_id: String,
        status: Status,
    ) -> StepRunGet200Response {
        StepRunGet200Response {
            metadata: Box::new(metadata),
            tenant_id,
            job_run_id,
            job_run: None,
            step_id,
            step: None,
            child_workflows_count: None,
            parents: None,
            child_workflow_runs: None,
            worker_id: None,
            input: None,
            output: None,
            status,
            requeue_after: None,
            result: None,
            error: None,
            started_at: None,
            started_at_epoch: None,
            finished_at: None,
            finished_at_epoch: None,
            timeout_at: None,
            timeout_at_epoch: None,
            cancelled_at: None,
            cancelled_at_epoch: None,
            cancelled_reason: None,
            cancelled_error: None,
        }
    }
}
///
#[derive(Clone, Copy, Debug, Eq, PartialEq, Ord, PartialOrd, Hash, Serialize, Deserialize)]
pub enum Status {
    #[serde(rename = "PENDING")]
    Pending,
    #[serde(rename = "PENDING_ASSIGNMENT")]
    PendingAssignment,
    #[serde(rename = "ASSIGNED")]
    Assigned,
    #[serde(rename = "RUNNING")]
    Running,
    #[serde(rename = "SUCCEEDED")]
    Succeeded,
    #[serde(rename = "FAILED")]
    Failed,
    #[serde(rename = "CANCELLED")]
    Cancelled,
    #[serde(rename = "CANCELLING")]
    Cancelling,
    #[serde(rename = "BACKOFF")]
    Backoff,
}

impl Default for Status {
    fn default() -> Status {
        Self::Pending
    }
}