gflow 0.4.13

A lightweight, single-node job scheduler written in Rust.
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

use anyhow::Result;
use gflow::utils::parse_job_ids;

pub async fn handle_release(
    config_path: &Option<std::path::PathBuf>,
    job_ids_str: String,
) -> Result<()> {
    let client = gflow::create_client(config_path)?;

    let job_ids = parse_job_ids(&job_ids_str)?;

    for &job_id in &job_ids {
        // Get the job from the daemon to check its state
        let Some(job) = gflow::client::get_job_or_warn(&client, job_id).await? else {
            continue;
        };

        // Check if the job can be released
        if let Err(e) =
            gflow::utils::validate_job_state(&job, gflow::core::job::JobState::Hold, "released")
        {
            eprintln!("Error: {}", e);
            continue;
        }

        // Release the job
        client.release_job(job_id).await?;
        println!("Job {} released back to queue.", job_id);
    }

    Ok(())
}