Optimize email sending by doing it in parallel

PolpOnline · Jan 7, 2025 · d36b047 · d36b047
1 parent 72a2ff9
commit d36b047
Showing 1 changed file with 9 additions and 4 deletions.
diff --git a/src/backend/src/workers/email_worker.rs b/src/backend/src/workers/email_worker.rs
@@ -61,12 +61,17 @@ impl Worker<()> for EmailWorker {
             }
         });
 
-        for email in emails {
+        let emails_fut = emails.map(|email| async {
             match self.smtp_client.send(email).await {
-                Ok(_) => {}
-                Err(e) => error!("Scheduled task: Error sending email: {}", e),
+                Ok(_) => Ok(()),
+                Err(e) => {
+                    error!("Scheduled task: Error sending email: {}", e);
+                    Err(e)
+                }
             }
-        }
+        });
+
+        futures::future::join_all(emails_fut).await;
 
         let down_ids = down_services
             .iter()