Format

Author: slinkydeveloper

src/lib.rs

@@ -1,14 +1,14 @@
-use std::fmt;
 use pyo3::create_exception;
 use pyo3::prelude::*;
 use pyo3::types::{PyBytes, PyNone, PyString};
+use restate_sdk_shared_core::fmt::{set_error_formatter, ErrorFormatter};
 use restate_sdk_shared_core::{
     CallHandle, CoreVM, DoProgressResponse, Error, Header, IdentityVerifier, Input, NonEmptyValue,
     NotificationHandle, ResponseHead, RetryPolicy, RunExitResult, TakeOutputResult, Target,
     TerminalFailure, VMOptions, Value, CANCEL_NOTIFICATION_HANDLE, VM,
 };
+use std::fmt;
 use std::time::{Duration, SystemTime};
-use restate_sdk_shared_core::fmt::{set_error_formatter, ErrorFormatter};
 
 // Current crate version
 const CURRENT_VERSION: &str = env!("CARGO_PKG_VERSION");
@@ -144,18 +144,26 @@ impl PyExponentialRetryConfig {
 
 impl From<PyExponentialRetryConfig> for RetryPolicy {
     fn from(value: PyExponentialRetryConfig) -> Self {
-        if value.initial_interval.is_some() || value.max_attempts.is_some() || value.max_duration.is_some() || value.max_interval.is_some() || value.factor.is_some() {
+        if value.initial_interval.is_some()
+            || value.max_attempts.is_some()
+            || value.max_duration.is_some()
+            || value.max_interval.is_some()
+            || value.factor.is_some()
+        {
             // If any of the values are set, then let's create the exponential retry policy
             RetryPolicy::Exponential {
                 initial_interval: Duration::from_millis(value.initial_interval.unwrap_or(50)),
                 max_attempts: value.max_attempts,
                 max_duration: value.max_duration.map(Duration::from_millis),
                 factor: value.factor.unwrap_or(2.0) as f32,
-                max_interval: value.max_interval.map(Duration::from_millis).or_else(|| Some(Duration::from_secs(10))),
+                max_interval: value
+                    .max_interval
+                    .map(Duration::from_millis)
+                    .or_else(|| Some(Duration::from_secs(10))),
             }
         } else {
             // Let's use retry policy infinite here, which will give back control to the invocation retry policy
-         RetryPolicy::Infinite
+            RetryPolicy::Infinite
         }
     }
 }