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)) } }