retry fmt

Author: jtguibas

crates/calibrator/src/lib.rs

@@ -90,7 +90,8 @@ impl Calibrator for SinglePassCalibrator {
         //
         // The model is based on the following formula:
         //
-        // bidPricePerPGU = (costPerHour / averageUtilizationRate) * (1 + profitMargin) / maxThroughputPerHour
+        // bidPricePerPGU = (costPerHour / averageUtilizationRate) * (1 + profitMargin) /
+        // maxThroughputPerHour
         let pgus_per_hour = pgus_per_second * 3600.0;
         let utilized_pgus_per_hour = pgus_per_hour * self.utilization_rate;
         let optimal_pgu_price = self.cost_per_hour / utilized_pgus_per_hour;

crates/rpc/src/retry.rs

@@ -55,10 +55,10 @@ where
                 // Check for tonic status errors.
                 if let Some(status) = e.downcast_ref::<tonic::Status>() {
                     match status.code() {
-                        Code::Unavailable
-                        | Code::DeadlineExceeded
-                        | Code::Internal
-                        | Code::Aborted => {
+                        Code::Unavailable |
+                        Code::DeadlineExceeded |
+                        Code::Internal |
+                        Code::Aborted => {
                             warn!(
                                 "Network temporarily unavailable when {} due to {}, retrying...",
                                 operation_name,
@@ -83,14 +83,14 @@ where
                 } else {
                     // Check for common transport errors.
                     let error_msg = e.to_string().to_lowercase();
-                    let is_transient = error_msg.contains("tls handshake")
-                        || error_msg.contains("dns error")
-                        || error_msg.contains("connection reset")
-                        || error_msg.contains("broken pipe")
-                        || error_msg.contains("transport error")
-                        || error_msg.contains("failed to lookup")
-                        || error_msg.contains("timeout")
-                        || error_msg.contains("deadline exceeded");
+                    let is_transient = error_msg.contains("tls handshake") ||
+                        error_msg.contains("dns error") ||
+                        error_msg.contains("connection reset") ||
+                        error_msg.contains("broken pipe") ||
+                        error_msg.contains("transport error") ||
+                        error_msg.contains("failed to lookup") ||
+                        error_msg.contains("timeout") ||
+                        error_msg.contains("deadline exceeded");
 
                     if is_transient {
                         warn!(