fix for commit/transaction error (#436)

Tried to commit transaction on connection "{model}", but it does not have one open!
dbt-labs · May 19, 2017 · 5f04aae · 5f04aae
1 parent 02e8e66
commit 5f04aae
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/dbt/adapters/redshift.py b/dbt/adapters/redshift.py
@@ -60,7 +60,9 @@ def drop(cls, profile, relation, relation_type, model_name=None):
 
             connection = cls.get_connection(profile, model_name)
 
-            cls.commit(connection)
+            if connection.get('transaction_open'):
+                cls.commit(connection)
+
             cls.begin(profile, connection.get('name'))
 
             to_return = super(PostgresAdapter, cls).drop(