loopflow 0.12.31

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
31
32

use std::num::NonZeroU32;

use crate::exec::{Exec, ExecCursor, ExecFilter, ExecPage};
use crate::id::ExecId;

use super::{run_sqlite, Store, StoreResult};

impl Store {
    pub async fn exec(&self, id: &ExecId) -> StoreResult<Option<Exec>> {
        let id = id.clone();
        run_sqlite(&self.sqlite, move |store| store.exec(&id)).await
    }

    pub async fn resolve_exec(&self, selector: &str) -> StoreResult<Option<Exec>> {
        let selector = selector.to_string();
        run_sqlite(&self.sqlite, move |store| store.resolve_exec(&selector)).await
    }

    pub async fn execs(
        &self,
        filter: &ExecFilter,
        after: Option<&ExecCursor>,
        limit: NonZeroU32,
    ) -> StoreResult<ExecPage> {
        let filter = filter.clone();
        let after = after.cloned();
        run_sqlite(&self.sqlite, move |store| {
            store.execs(&filter, after.as_ref(), limit)
        })
        .await
    }
}