From 75eb4d5c3b3c7554807988d28c978b3cebf252b3 Mon Sep 17 00:00:00 2001 From: Jacob Beck Date: Wed, 18 Jul 2018 14:58:46 -0600 Subject: [PATCH] also did not need this --- dbt/adapters/default/impl.py | 9 --------- 1 file changed, 9 deletions(-) diff --git a/dbt/adapters/default/impl.py b/dbt/adapters/default/impl.py index 4e903ac1a8a..5b91da7c315 100644 --- a/dbt/adapters/default/impl.py +++ b/dbt/adapters/default/impl.py @@ -660,15 +660,6 @@ def clear_transaction(cls, profile, conn_name='master'): cls.commit(profile, conn) return conn_name - @classmethod - def clear_all_transactions(cls, profile): - for conn_name, transaction in connections_in_use.items(): - if transaction.get('transaction_open'): - print('found open transaction {}, rolling it back'.format(conn_name)) - cls.rollback(transaction) - print('clearing transaction') - cls.clear_transaction(profile, conn_name) - @classmethod def execute_one(cls, profile, sql, model_name=None, auto_begin=False): cls.get_connection(profile, model_name)