From 9a5f9d4ea949ac693a39ce431a6bb0a0f33b52e2 Mon Sep 17 00:00:00 2001 From: Logan Johnson Date: Fri, 28 Aug 2026 17:01:25 -0400 Subject: [PATCH] Integrate workflow delivery with domain datastore tracing Co-authored-by: Larry <8cf5a83f590ec0955b11647d1c88f796a98e088c30a492c58e0e46c3026ae7a4@buzz.block.builderlab.xyz> Signed-off-by: Logan Johnson --- crates/buzz-db/src/store/workflow_delivery.rs | 3 +++ 1 file changed, 3 insertions(+) diff --git a/crates/buzz-db/src/store/workflow_delivery.rs b/crates/buzz-db/src/store/workflow_delivery.rs index 71beb62b2e..8dda48ea2d 100644 --- a/crates/buzz-db/src/store/workflow_delivery.rs +++ b/crates/buzz-db/src/store/workflow_delivery.rs @@ -1,12 +1,14 @@ //! Atomic workflow output persistence and captured-revision reads. use crate::{event, insert_mentions_in_transaction, Db, Result}; use buzz_core::{tenant::CommunityId, StoredEvent}; +use buzz_datastore_tracing::datastore_span; use uuid::Uuid; impl Db { /// Atomically persist a visible event, its thread metadata/mentions, and all /// required notifications. No caller may publish any row until this commits. /// Cancellation or any insert failure rolls the entire bundle back. + #[datastore_span(name = "insert_event_with_notifications", system = "postgresql")] pub async fn insert_event_with_notifications( &self, community_id: CommunityId, @@ -47,6 +49,7 @@ impl Db { } /// Read a captured workflow definition without reviving explicitly deleted revisions. + #[datastore_span(name = "get_workflow_revision", system = "postgresql")] pub async fn get_workflow_revision( &self, community_id: CommunityId,