Skip to main content

open_job_state_db

tinyflow_framework::state::job_state_dir

Function open_job_state_db 

Source 
pub async fn open_job_state_db(
    work_dir: &Path,
) -> StreamResult<Arc<dyn StateStore>>