scriptoriumadmin/fabro
1
0
Fork 0
mirror of https://github.com/fabro-sh/fabro.git synced 2026-10-07 03:00:29 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 4

test(harness): flush workflow store events before returning

Browse source 
Flush the async store logger in workflow test helpers before returning so
callers that reopen the run store immediately do not observe partial state.
This removes the race behind the Linux git checkpoint CI failure.
This commit is contained in:
Bryan Helmkamp 2026-04-18 09:30:42 -04:00
parent 459433baa5
commit 8d39f31a62
No known key found for this signature in database
1 changed files with 8 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
lib/crates/fabro-workflow/src/test_support.rs
View file

@ -165,6 +165,9 @@ pub async fn run_graph(
)
.await;
let executed = pipeline::execute(initialized.initialized).await;
// Tests often reopen the run store immediately after `run()` returns.
// Flush the async store logger first so they don't observe partial state.
initialized.store_logger.flush().await;
executed.outcome
}
@ -189,8 +192,8 @@ pub async fn run_graph_with_state(
)
.await;
let executed = pipeline::execute(initialized.initialized).await;
let outcome = executed.outcome?;
initialized.store_logger.flush().await;
let outcome = executed.outcome?;
let state = executed
.run_store
.state()
@ -222,6 +225,7 @@ pub async fn run_graph_with_hooks(
)
.await;
let executed = pipeline::execute(initialized.initialized).await;
initialized.store_logger.flush().await;
executed.outcome
}
@ -248,8 +252,8 @@ pub async fn run_graph_with_hooks_and_state(
)
.await;
let executed = pipeline::execute(initialized.initialized).await;
let outcome = executed.outcome?;
initialized.store_logger.flush().await;
let outcome = executed.outcome?;
let state = executed
.run_store
.state()
@ -280,6 +284,7 @@ pub async fn run_graph_from_checkpoint(
)
.await;
let executed = pipeline::execute(initialized.initialized).await;
initialized.store_logger.flush().await;
executed.outcome
}
@ -305,8 +310,8 @@ pub async fn run_graph_from_checkpoint_with_state(
)
.await;
let executed = pipeline::execute(initialized.initialized).await;
let outcome = executed.outcome?;
initialized.store_logger.flush().await;
let outcome = executed.outcome?;
let state = executed
.run_store
.state()