diff --git a/crates/churn/src/agent/grpc_client.rs b/crates/churn/src/agent/grpc_client.rs index c988f25..be9639a 100644 --- a/crates/churn/src/agent/grpc_client.rs +++ b/crates/churn/src/agent/grpc_client.rs @@ -67,13 +67,16 @@ impl GrpcClient { namespace: namespace.into(), id: id.map(|i| i.into()), }) - .await?; + .await + .inspect_err(|e| tracing::warn!("failed to establish a connection: {}", e))?; tracing::debug!("setup stream: {}", namespace); let mut inner = resp.into_inner(); while let Ok(Some(message)) = inner.message().await { tracing::debug!("received message: {}", namespace); - exec.execute(message).await?; + exec.execute(message) + .await + .inspect_err(|e| tracing::warn!("failed to handle message: {}", e))?; } Ok(())