diff --git a/testing-framework/workflows/src/workloads/transaction/expectation.rs b/testing-framework/workflows/src/workloads/transaction/expectation.rs
index 0be5763..bd6ceee 100644
--- a/testing-framework/workflows/src/workloads/transaction/expectation.rs
+++ b/testing-framework/workflows/src/workloads/transaction/expectation.rs
@@ -122,8 +122,13 @@ impl Expectation for TxInclusionExpectation {
                             }
                         }
                     }
-                    Err(broadcast::error::RecvError::Lagged(_)) => {}
-                    Err(broadcast::error::RecvError::Closed) => break,
+                    Err(broadcast::error::RecvError::Lagged(skipped)) => {
+                        tracing::debug!(skipped, "tx inclusion capture lagged");
+                    }
+                    Err(broadcast::error::RecvError::Closed) => {
+                        tracing::debug!("tx inclusion capture feed closed");
+                        break;
+                    }
                 }
             }
             tracing::debug!("tx inclusion capture task exiting");
diff --git a/testing-framework/workflows/src/workloads/util.rs b/testing-framework/workflows/src/workloads/util.rs
index c65fa52..034e9be 100644
--- a/testing-framework/workflows/src/workloads/util.rs
+++ b/testing-framework/workflows/src/workloads/util.rs
@@ -16,6 +16,10 @@ pub fn find_channel_op<F>(block: &Block<SignedMantleTx>, matcher: &mut F) -> Opt
 where
     F: FnMut(&Op) -> Option<MsgId>,
 {
+    debug!(
+        txs = block.transactions().len(),
+        "scanning block for channel op"
+    );
     for tx in block.transactions() {
         for op in &tx.mantle_tx().ops {
             if let Some(msg_id) = matcher(op) {