removed assert table exists

Author: arbiv

integration_tests/tests/dbt_project.py

@@ -277,19 +277,3 @@ def write_yaml(self, content: dict, name: Optional[str] = None):
             YAML().dump(content, f)
         yield path
         path.unlink()
-
-    def assert_table_exists(self, table_name: str):
-        table_exists_query = f"""
-            select 1
-            from information_schema.tables
-            where table_name = '{table_name}'
-        """
-        try:
-            table_exists_result = self.run_query(table_exists_query)
-        except IndexError:
-            table_exists_result = []
-        except Exception as e:
-            raise AssertionError(f"Failed to check if {table_name} exists: {e}")
-        assert (
-            table_exists_result
-        ), f"{table_name} table does not exist. The artifact was not created."

integration_tests/tests/test_dbt_artifacts/test_groups.py

@@ -138,7 +138,6 @@ def test_model_and_groups(dbt_project: DbtProject, tmp_path):
             dbt_project.dbt_runner.vars["disable_dbt_artifacts_autoupload"] = False
             dbt_project.dbt_runner.vars["disable_run_results"] = False
             dbt_project.dbt_runner.run(select=model_name)
-            dbt_project.assert_table_exists("dbt_models")
 
             models = dbt_project.read_table(
                 "dbt_models", where=f"name = '{model_name}'", raise_if_empty=True
@@ -228,7 +227,6 @@ def test_two_groups(dbt_project: DbtProject, tmp_path):
             dbt_project.dbt_runner.vars["disable_dbt_artifacts_autoupload"] = False
             dbt_project.dbt_runner.vars["disable_run_results"] = False
             dbt_project.dbt_runner.run(select=f"{model_name_1} {model_name_2}")
-            dbt_project.assert_table_exists("dbt_models")
 
             # Check both models and their groups/owners
             assert_group_row_in_db_groups(
@@ -297,7 +295,6 @@ def test_test_group_attribute(dbt_project: DbtProject, tmp_path):
         try:
             dbt_project.dbt_runner.vars["disable_dbt_artifacts_autoupload"] = False
             dbt_project.dbt_runner.run(select=model_name)
-            dbt_project.assert_table_exists("dbt_tests")
             tests = dbt_project.read_table(
                 "dbt_tests", where="name LIKE 'unique%'", raise_if_empty=True
             )
@@ -362,7 +359,6 @@ def test_test_override_group(dbt_project: DbtProject, tmp_path):
         try:
             dbt_project.dbt_runner.vars["disable_dbt_artifacts_autoupload"] = False
             dbt_project.dbt_runner.run(select=model_name)
-            dbt_project.assert_table_exists("dbt_tests")
             tests = dbt_project.read_table(
                 "dbt_tests", where="name LIKE 'unique%'", raise_if_empty=True
             )
@@ -430,7 +426,6 @@ def test_seed_group_attribute(dbt_project: DbtProject, tmp_path):
             dbt_project.dbt_runner.vars["disable_dbt_artifacts_autoupload"] = False
             dbt_project.dbt_runner.vars["disable_run_results"] = False
             dbt_project.dbt_runner.seed(select=seed_name)
-            dbt_project.assert_table_exists("dbt_seeds")
             seeds = dbt_project.read_table(
                 "dbt_seeds", where=f"name = '{seed_name}'", raise_if_empty=True
             )
@@ -507,7 +502,6 @@ def test_snapshot_group_attribute(dbt_project: DbtProject, tmp_path):
             dbt_project.dbt_runner.vars["disable_dbt_artifacts_autoupload"] = False
             dbt_project.dbt_runner.vars["disable_run_results"] = False
             dbt_project.dbt_runner.snapshot()
-            dbt_project.assert_table_exists("dbt_snapshots")
 
             snapshots = dbt_project.read_table(
                 "dbt_snapshots", where=f"name = '{snapshot_name}'", raise_if_empty=False