stormchaser-engine 1.3.0

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

use anyhow::Result;
use serde_json::Value;

/// Releases the quota acquired for a specific step instance, marking it as completed or failed in the quota system.
pub async fn release_step_quota_for_instance(
    executor: &mut sqlx::PgConnection,
    run_id: stormchaser_model::RunId,
    step_id: stormchaser_model::StepInstanceId,
) -> Result<()> {
    let row: Option<(String, Value)> =
        crate::db::steps::get_step_type_and_spec(&mut *executor, step_id)
            .await
            .ok();

    if let Some((step_type, spec)) = row {
        let (cpu, mem) = crate::resource_utils::get_step_resource_requirements(&step_type, &spec);
        if cpu > 0.0 || mem > 0 {
            let _ = crate::db::release_step_quota(&mut *executor, run_id, cpu, mem).await;
        }
    }

    Ok(())
}