Cleanup

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)

test/integration/029_docs_generate_tests/test_docs_generate.py

@@ -483,6 +483,7 @@ def test__bigquery__nested_models(self):
             },
         }
         self.verify_manifest(expected_manifest)
+
     @use_profile('redshift')
     def test__redshift__run_and_generate(self):
         self.run_and_generate()

test/integration/base.py

@@ -289,13 +289,6 @@ def use_profile(self, adapter_type):
             self.run_sql('DROP SCHEMA IF EXISTS {} CASCADE'.format(schema))
             self.run_sql('CREATE SCHEMA {}'.format(schema))
 
-    def _reconnect(self):
-        """Disconnect and then reconnect. setUp() must be complete!"""
-        self.handle.close()
-        self.adapter.cleanup_connections()
-        connection = self.adapter.acquire_connection(self._profile, '__test')
-        self.handle = connection.get('handle')
-
     def tearDown(self):
         os.remove(DBT_PROFILES)
         os.remove("dbt_project.yml")