diff --git a/lib/components/fabro-petri/src/projector.rs b/lib/components/fabro-petri/src/projector.rs index 8c5e7e96f..3215a842b 100644 --- a/lib/components/fabro-petri/src/projector.rs +++ b/lib/components/fabro-petri/src/projector.rs @@ -52,6 +52,7 @@ use petri_execution::events::{self, EventId, EventSource, RunEvent}; use petri_execution::{Access, RunKey, RunStore as _, inspect}; use petri_store::StoreError; use serde::{Deserialize, Serialize}; +use tokio::sync::Mutex as AsyncMutex; use tokio::time; use tracing::{debug, info, warn}; @@ -153,7 +154,7 @@ pub struct Projector { slots: Mutex>, /// One pass at a time per run: a signalled pass and the startup pass /// over the same run never interleave their reads and writes. - passes: Mutex>>>, + passes: Mutex>>>, /// Test-only: stop the next pass after its reads, before its view /// transaction, as a crash there would. fault: AtomicBool,