Skip to main content

stasis/domain/runtime/
workflow_definition.rs

1use chrono::{DateTime, Utc};
2
3#[derive(Clone, Debug, Eq, PartialEq)]
4pub struct WorkflowDefinition {
5    pub workflow_id: String,
6    pub queue: String,
7    pub latest_revision_id: String,
8    pub created_at: DateTime<Utc>,
9    pub updated_at: DateTime<Utc>,
10}
11
12#[derive(Clone, Debug, Eq, PartialEq)]
13pub struct WorkflowRevision {
14    pub workflow_id: String,
15    pub revision_id: String,
16    pub source: String,
17    pub graph_state_json: String,
18    pub compiler_metadata_json: String,
19    pub graph_modules_csv: String,
20    pub graph_function_steps_csv: String,
21    pub graph_function_inputs_json: String,
22    pub reflected_at_utc: DateTime<Utc>,
23    pub executable_count: usize,
24    pub reflection_receipt_json: String,
25}