Skip to content

Commit aa0676c

Browse files
committed
chore(tracing): improve bundle tracing, break when receiver is dropped
1 parent 6ecca6e commit aa0676c

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/tasks/cache/bundle.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -89,10 +89,12 @@ impl BundlePoller {
8989
.await
9090
.inspect_err(|err| debug!(%err, "Error fetching bundles"))
9191
{
92+
let _guard = span.entered();
9293
debug!(count = ?bundles.len(), "found bundles");
9394
for bundle in bundles.into_iter() {
9495
if let Err(err) = outbound.send(bundle) {
9596
error!(err = ?err, "Failed to send bundle - channel is dropped");
97+
break;
9698
}
9799
}
98100
}

0 commit comments

Comments
 (0)