From a821ca219b4c824440637047bb8b77806d225b6c Mon Sep 17 00:00:00 2001 From: GroovieGermanikus Date: Fri, 22 Mar 2024 10:56:40 +0100 Subject: [PATCH] stream: replace panic with log+reconnect --- src/grpc_subscription_autoreconnect_streams.rs | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/grpc_subscription_autoreconnect_streams.rs b/src/grpc_subscription_autoreconnect_streams.rs index a6d0506..114a75a 100644 --- a/src/grpc_subscription_autoreconnect_streams.rs +++ b/src/grpc_subscription_autoreconnect_streams.rs @@ -80,7 +80,8 @@ pub fn create_geyser_reconnecting_stream( (ConnectionState::WaitReconnect(attempt + 1), Message::Connecting(attempt)) }, Err(geyser_grpc_task_error) => { - panic!("task aborted - should not happen :{geyser_grpc_task_error}"); + warn!("connection task aborted on {} - retrying: {:?}", grpc_source, geyser_grpc_task_error); + (ConnectionState::WaitReconnect(attempt + 1), Message::Connecting(attempt)) } }