loopflow 0.12.7

Run steps and flows with coding agents
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

use std::sync::Arc;

use anyhow::{anyhow, Result};

use crate::durable::WorkRef;
use crate::store::{open_existing_store, SharedStore};

/// Run one Project or Task body under the exact ambient Run lease.
pub async fn run_work(work: WorkRef) -> Result<()> {
    let store: SharedStore = Arc::new(
        open_existing_store()
            .await
            .ok_or_else(|| anyhow!("no Loopflow registry on this machine"))?,
    );
    let lease = crate::ops::required_run_lease(&store).await?;
    if lease.work != work {
        anyhow::bail!(
            "ambient Run lease owns {} {}, not {} {}",
            lease.work.kind(),
            lease.work.id(),
            work.kind(),
            work.id(),
        );
    }
    match work {
        WorkRef::Project(id) => crate::project::runner::run(store, id, &lease).await,
        WorkRef::Task(id) => crate::task::runner::run(store, id, &lease).await,
        WorkRef::Wave(id) => anyhow::bail!("Wave {id} is hosted by its resident, not a child body"),
    }
}