diff --git a/clouds/redshift/common/test_utils/__init__.py b/clouds/redshift/common/test_utils/__init__.py
index a547aedc0..71b757b20 100644
--- a/clouds/redshift/common/test_utils/__init__.py
+++ b/clouds/redshift/common/test_utils/__init__.py
@@ -13,6 +13,7 @@ def run_query(query):
         user=os.environ['RS_USER'],
         password=os.environ['RS_PASSWORD'],
     )
+    conn.autocommit = True
     cursor = conn.cursor()
     cursor.execute(query.replace('@@RS_SCHEMA@@', os.environ['RS_SCHEMA']))
     try: