gflow 0.4.15

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
33
34
35
36
37
38
39
40

use anyhow::{anyhow, Context, Result};
use gflow::client::Client;

/// Resolve job ID or dependency expression from string (handles @ shorthand notation)
///
/// Accepts:
/// - Numeric job ID: "123"
/// - Most recent job: "@"
/// - Nth most recent job: "@~1", "@~2", etc.
///
/// This is a unified function that handles both job ID and dependency resolution.
pub async fn resolve_job_id(client: &Client, job_id_str: &str) -> Result<u32> {
    let trimmed = job_id_str.trim();

    if trimmed.starts_with('@') {
        // Use dependency resolution to handle @ shorthand
        let username = gflow::platform::get_current_username();
        client
            .resolve_dependency(&username, trimmed)
            .await
            .with_context(|| format!("Failed to resolve job ID '{}'", trimmed))
    } else {
        // Parse as numeric job ID
        trimmed
            .parse::<u32>()
            .map_err(|_| anyhow!("Invalid job ID: {}", trimmed))
    }
}

/// Resolve dependency expression to job ID
///
/// This is an alias for `resolve_job_id` to maintain backward compatibility.
/// Both functions accept the same input formats:
/// - Numeric job ID: "123"
/// - Most recent job: "@"
/// - Nth most recent job: "@~1", "@~2", etc.
#[inline]
pub async fn resolve_dependency(client: &Client, depends_on: &str) -> Result<u32> {
    resolve_job_id(client, depends_on).await
}