We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b7384dd commit 6b30126Copy full SHA for 6b30126
1 file changed
bottlecap/src/traces/span_dedup_service.rs
@@ -45,6 +45,9 @@ impl DedupHandle {
45
.send(DedupCommand::CheckAndAdd(key, response_tx))
46
.map_err(DedupError::SendError)?;
47
48
+ // Sometimes the dedup service fails to send a response for unknown reasons, so we
49
+ // timeout after 5 seconds to avoid blocking the caller forever. We may remove the
50
+ // timeout if we can figure out and fix the root cause.
51
tokio::time::timeout(Duration::from_secs(5), response_rx)
52
.await
53
.map_err(|_| DedupError::Timeout)?
0 commit comments