f

golemfactory · Oct 25, 2023 · 77a9b99 · 77a9b99
1 parent d9fb049
commit 77a9b99
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 4 deletions.
diff --git a/crates/erc20_payment_lib/src/sender/service.rs b/crates/erc20_payment_lib/src/sender/service.rs
@@ -343,7 +343,10 @@ pub async fn process_transactions(
             }
         }
 
-        tokio::time::sleep(std::time::Duration::from_secs(payment_setup.process_interval)).await;
+        tokio::time::sleep(std::time::Duration::from_secs(
+            payment_setup.process_interval,
+        ))
+        .await;
     }
     Ok(())
 }
@@ -407,8 +410,10 @@ pub async fn service_loop(
                 Ok(token_transfer_map) => token_transfer_map,
                 Err(e) => {
                     log::error!("Error in gather transactions, driver will be stuck, Fix DB to continue {:?}", e);
-                    tokio::time::sleep(std::time::Duration::from_secs(payment_setup.process_interval))
-                        .await;
+                    tokio::time::sleep(std::time::Duration::from_secs(
+                        payment_setup.process_interval,
+                    ))
+                    .await;
                     continue;
                 }
             };

diff --git a/crates/erc20_payment_lib/src/service.rs b/crates/erc20_payment_lib/src/service.rs
@@ -229,6 +229,9 @@ pub async fn confirm_loop(
     payment_setup: &PaymentSetup,
 ) {
     loop {
-        tokio::time::sleep(std::time::Duration::from_secs(payment_setup.process_interval)).await;
+        tokio::time::sleep(std::time::Duration::from_secs(
+            payment_setup.process_interval,
+        ))
+        .await;
     }
 }