Skip to main content

tinyflow_framework/state/
job_state_dir.rs

1//! Open the job-level SQLite database under a work directory.
2
3use std::path::Path;
4use std::sync::Arc;
5
6use crate::state::SqliteJobStateStore;
7use tinyflow_api::error::StreamResult;
8use tinyflow_api::state::StateStore;
9
10pub async fn open_job_state_db(work_dir: &Path) -> StreamResult<Arc<dyn StateStore>> {
11    let path = work_dir.join("job/state.db");
12    SqliteJobStateStore::open(&path).await
13}