Skip to content

Commit 7c6ec8f

Browse files
committed
feat: improve clarity of the source send cancelled error message
The `source send cancelled` does not immediately convey possible causes and does not provide actionable feedback. Since this error most probably indicates backpressure-related errors, let’s be explicit about it.
1 parent 0141894 commit 7c6ec8f

2 files changed

Lines changed: 6 additions & 1 deletion

File tree

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
Updated the `source send cancelled` error message to point towards possible causes.
2+
This error usually happens either because a pipeline is shutting down or because
3+
of backpressure.
4+
5+
authors: clementd-dd

lib/vector-core/src/source_sender/output.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ impl Drop for UnsentEventCount {
7676
let _enter = self.span.enter();
7777
internal_event::emit(ComponentEventsDropped::<UNINTENTIONAL> {
7878
count: self.count,
79-
reason: "Source send cancelled.",
79+
reason: "Source send interrupted mid-flight; pipeline may be overloaded or shutting down.",
8080
});
8181
}
8282
}

0 commit comments

Comments
 (0)