diff --git a/src/cloudflare.rs b/src/cloudflare.rs
index 41796df..2be3e40 100644
--- a/src/cloudflare.rs
+++ b/src/cloudflare.rs
@@ -58,13 +58,13 @@ impl CloudflareClient {
         if new_ip == self.current_ip {
             return Ok(());
         }
-        self.update_dns_records(new_ip).await;
+        self.update_dns_records(new_ip).await?;
         self.current_ip = new_ip;
 
         Ok(())
     }
 
-    async fn update_dns_records(&self, new_ip: Ipv4Addr) {
+    async fn update_dns_records(&self, new_ip: Ipv4Addr) -> Result<()> {
         for domain in &self.domains {
             let records = match self.get_dns_records(domain).await {
                 Ok(r) => r,
@@ -91,9 +91,12 @@ impl CloudflareClient {
                         "On {}, failed to update {}: '{}' -> '{}': {:?}",
                         &domain, record.name, record.content, &new_ip_s, &e
                     );
+                    return Err(e);
                 }
             }
         }
+
+        Ok(())
     }
 
     async fn get_dns_records(&self, domain: &str) -> Result<Vec<DnsRecord>> {