get rid of forever loop

golemfactory · Oct 26, 2023 · 1e04506 · 1e04506
1 parent 62f9026
commit 1e04506
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/agent/provider/src/payments/payments.rs b/agent/provider/src/payments/payments.rs
@@ -823,7 +823,8 @@ impl Handler<IssueInvoice> for Payments {
         async move {
             log::debug!("Issuing invoice {}.", serde_json::to_string(&invoice)?);
 
-            loop {
+            let max_retries = 3;
+            for _ in 0..max_retries {
                 match provider_ctx.payment_api.issue_invoice(&invoice).await {
                     Ok(invoice) => {
                         log::info!("Invoice [{}] issued.", invoice.invoice_id);
@@ -836,6 +837,7 @@ impl Handler<IssueInvoice> for Payments {
                     }
                 }
             }
+            Err(anyhow!("Failed to issue invoice after {} retries.", max_retries))
         }
         .boxed_local()
     }