diff --git a/query-engine/connector-test-kit-rs/query-tests-setup/src/connector_tag/js/external_process.rs b/query-engine/connector-test-kit-rs/query-tests-setup/src/connector_tag/js/external_process.rs index 7ab0e6e8a021..7059d64dc641 100644 --- a/query-engine/connector-test-kit-rs/query-tests-setup/src/connector_tag/js/external_process.rs +++ b/query-engine/connector-test-kit-rs/query-tests-setup/src/connector_tag/js/external_process.rs @@ -125,7 +125,10 @@ fn start_rpc_thread(mut receiver: mpsc::Receiver) -> Result<()> { let sender = pending_requests.remove(response.id()).unwrap(); match response { jsonrpc_core::Output::Success(success) => { - sender.send(success.result).unwrap(); + // The other end may be dropped if the whole + // request future was dropped and not polled to + // completion, so we ignore send errors here. + _ = sender.send(success.result); } jsonrpc_core::Output::Failure(err) => { panic!("error response from jsonrpc: {err:?}")