Fix params arg not sent to execute() via connect_and_fetchall() (#398)

snowflakedb · May 4, 2020 · 8560834 · 8560834
1 parent 7e26e9b
commit 8560834
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/runners/helpers/db.py b/src/runners/helpers/db.py
@@ -194,9 +194,9 @@ def connect_and_execute(queries=None):
     return connection
 
 
-def connect_and_fetchall(query):
+def connect_and_fetchall(query, params=None):
     ctx = connect()
-    return ctx, execute(query).fetchall()
+    return ctx, execute(query, params=params).fetchall()
 
 
 def fetch_latest(table, col='event_time', where=''):