diff --git a/backend/windmill-worker/src/pg_executor.rs b/backend/windmill-worker/src/pg_executor.rs
index d3e085a7dd..5aab50c3f9 100644
--- a/backend/windmill-worker/src/pg_executor.rs
+++ b/backend/windmill-worker/src/pg_executor.rs
@@ -372,7 +372,7 @@ pub async fn do_postgresql(
         }
     } else {
         cached_client = None;
-        new_client = None;
+        new_client = Some(new_pg_connection(&database, use_iam_auth).await?);
     }
 
     let (sig, typed_schema) = parse_pgsql_sig_with_typed_schema(&query)