astro-run 1.0.0

A highly customizable workflow orchestrator
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

use super::{parser::WorkflowParser, Workflow};
use crate::{AstroRun, Error, Id, Result, UserWorkflow};

#[derive(Default)]
pub struct WorkflowBuilder {
  id: Option<Id>,
  config: Option<String>,
}

impl WorkflowBuilder {
  pub fn new() -> Self {
    Self::default()
  }

  pub fn id(mut self, id: impl Into<Id>) -> Self {
    self.id = Some(id.into());
    self
  }

  pub fn config(mut self, config: impl Into<String>) -> Self {
    self.config = Some(config.into());
    self
  }

  pub async fn build(self, astro_run: &AstroRun) -> Result<Workflow> {
    let config = self
      .config
      .ok_or(Error::init_error("Workflow config is required".to_string()))?;

    let user_workflow = UserWorkflow::try_from(config)?;
    let id = self.id.unwrap_or_else(|| uuid::Uuid::new_v4().to_string());

    let parser = WorkflowParser {
      id,
      user_workflow,
      astro_run,
    };

    parser.parse().await
  }
}