diff --git a/dozer-ingestion/src/connectors/snowflake/connection/client.rs b/dozer-ingestion/src/connectors/snowflake/connection/client.rs
index b2837788b6..dfc6538557 100644
--- a/dozer-ingestion/src/connectors/snowflake/connection/client.rs
+++ b/dozer-ingestion/src/connectors/snowflake/connection/client.rs
@@ -519,6 +519,7 @@ fn exec_iter(pool: Pool, query: String) -> ExecIter {
                 }
             }
             conn.return_();
+            break;
         }
         Ok::<(), SnowflakeError>(())
     });