From ee4850689ef090f73883411154d213cde9992de1 Mon Sep 17 00:00:00 2001 From: Bryan Helmkamp Date: Thu, 17 Sep 2026 22:58:31 -0400 Subject: [PATCH] Name the per-run pass lock's type through an import Co-Authored-By: Claude Fable 5.1 --- lib/components/fabro-petri/src/projector.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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,