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()
@@ -540,7 +541,7 @@ def test__redshift__run_and_generate(self):
  },
  }
  self.verify_catalog(expected_catalog)
- self.verify_manifest(self.expected_manifest())
+ self.verify_manifest(self.expected_seeded_manifest())
 
  @use_profile('redshift')
  def test__redshift__incremental_view(self):

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")