From 7c6ec8f71d89059afb72ec5351b491bdf6a641d3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Cl=C3=A9ment=20Delafargue?= Date: Fri, 26 Jun 2026 15:46:08 +0200 Subject: [PATCH] feat: improve clarity of the `source send cancelled` error message MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 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. --- ...ource_send_cancelled_message_clarification.enhancement.md | 5 +++++ lib/vector-core/src/source_sender/output.rs | 2 +- 2 files changed, 6 insertions(+), 1 deletion(-) create mode 100644 changelog.d/source_send_cancelled_message_clarification.enhancement.md diff --git a/changelog.d/source_send_cancelled_message_clarification.enhancement.md b/changelog.d/source_send_cancelled_message_clarification.enhancement.md new file mode 100644 index 0000000000000..51435d379f240 --- /dev/null +++ b/changelog.d/source_send_cancelled_message_clarification.enhancement.md @@ -0,0 +1,5 @@ +Updated the `source send cancelled` error message to point towards possible causes. +This error usually happens either because a pipeline is shutting down or because +of backpressure. + +authors: clementd-dd diff --git a/lib/vector-core/src/source_sender/output.rs b/lib/vector-core/src/source_sender/output.rs index 6569fd5ca0074..21774e2ec4cfd 100644 --- a/lib/vector-core/src/source_sender/output.rs +++ b/lib/vector-core/src/source_sender/output.rs @@ -76,7 +76,7 @@ impl Drop for UnsentEventCount { let _enter = self.span.enter(); internal_event::emit(ComponentEventsDropped:: { count: self.count, - reason: "Source send cancelled.", + reason: "Source send interrupted mid-flight; pipeline may be overloaded or shutting down.", }); } }