stormchaser-engine 1.4.2

A robust, distributed workflow engine for event-driven and human-triggered workflows.
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

use anyhow::Result;
use stormchaser_dsl::ast::Workflow;
use stormchaser_model::{RunId, StepInstanceId};
use uuid::Uuid;

pub async fn persist_artifact_metadata(
    tx: &mut sqlx::PgConnection,
    run_id: RunId,
    step_id: StepInstanceId,
    artifacts: Option<&serde_json::Map<String, serde_json::Value>>,
    workflow: &Workflow,
) -> Result<()> {
    let Some(artifacts) = artifacts else {
        return Ok(());
    };

    for (name, meta) in artifacts {
        let storage = workflow
            .storage
            .iter()
            .find(|s| s.artifacts.iter().any(|a| a.name == *name));

        if let Some(s) = storage {
            let connection_id: Option<Uuid> = if let Some(ref backend_name) = s.backend {
                crate::db::get_storage_backend_id_by_name(&mut *tx, backend_name).await?
            } else {
                crate::db::get_default_sfs_backend_id(&mut *tx).await?
            };

            if let Some(bid) = connection_id {
                let remote_path = format!("artifacts/{}/{}/{}", run_id, s.name, name);
                crate::db::insert_artifact_registry(
                    &mut *tx,
                    run_id,
                    step_id,
                    name,
                    stormchaser_model::ConnectionId::new(bid),
                    remote_path,
                    meta.clone(),
                )
                .await?;
            }
        }
    }
    Ok(())
}