skip more tests on fusion

Author: haritamar

integration_tests/tests/test_collect_metrics.py

@@ -150,6 +150,7 @@ def test_collect_group_by_metrics(test_id: str, dbt_project: DbtProject):
 
 # Anomalies currently not supported on ClickHouse
 @pytest.mark.skip_targets(["clickhouse"])
+@pytest.mark.skip_for_dbt_fusion
 def test_collect_metrics_unique_metric_name(test_id: str, dbt_project: DbtProject):
     args = DBT_TEST_ARGS.copy()
     args["metrics"].append(args["metrics"][0])

integration_tests/tests/test_dbt_artifacts/test_artifacts.py

@@ -52,6 +52,7 @@ def test_artifacts_collection_in_multiple_row_batches(dbt_project: DbtProject):
     assert len(existing_artifacts) == len(new_artifacts)
 
 
+@pytest.mark.skip_for_dbt_fusion
 def test_dbt_invocations(dbt_project: DbtProject):
     dbt_project.dbt_runner.vars["disable_dbt_invocation_autoupload"] = False
     dbt_project.dbt_runner.run(selector="one")
@@ -95,6 +96,7 @@ def test_metrics_anomaly_score(dbt_project: DbtProject):
 
 
 @pytest.mark.requires_dbt_version("1.8.0")
+@pytest.mark.skip_for_dbt_fusion
 def test_source_freshness_results(test_id: str, dbt_project: DbtProject):
     database_property, schema_property = get_database_and_schema_properties(
         dbt_project.target

integration_tests/tests/test_dbt_artifacts/test_groups.py

@@ -88,6 +88,7 @@ def assert_group_row_in_db_groups(dbt_project, group_name, owner_name, owner_ema
     ), f"Expected owner email '{owner_email}', got '{group_row.get('owner_email')}'"
 
 
+@pytest.mark.skip_for_dbt_fusion
 def test_model_and_groups(dbt_project: DbtProject, tmp_path):
     """
     Test that a model assigned to a group inherits the group attribute in the dbt_models artifact table.
@@ -161,6 +162,7 @@ def test_model_and_groups(dbt_project: DbtProject, tmp_path):
                 dbt_model_path.unlink()
 
 
+@pytest.mark.skip_for_dbt_fusion
 def test_two_groups(dbt_project: DbtProject, tmp_path):
     """
     Test that two models assigned to two different groups inherit the correct group attribute in the dbt_models artifact table.
@@ -453,6 +455,7 @@ def test_seed_group_attribute(dbt_project: DbtProject, tmp_path):
             )
 
 
+@pytest.mark.skip_for_dbt_fusion
 def test_snapshot_group_attribute(dbt_project: DbtProject, tmp_path):
     """
     Test that a snapshot assigned to a group inherits the group attribute in the dbt_snapshots artifact table.

integration_tests/tests/test_exposure_schema_validity.py

@@ -9,6 +9,7 @@ def seed(dbt_project: DbtProject):
     assert seed_result is True
 
 
+@pytest.mark.skip_for_dbt_fusion
 def test_exposure_schema_validity_existing_exposure_yml_invalid(
     test_id: str, dbt_project: DbtProject
 ):
@@ -27,6 +28,7 @@ def test_exposure_schema_validity_existing_exposure_yml_invalid(
     assert test_result.success is False
 
 
+@pytest.mark.skip_for_dbt_fusion
 def test_exposure_schema_validity_existing_exposure_yml_valid(
     test_id: str, dbt_project: DbtProject
 ):
@@ -45,13 +47,15 @@ def test_exposure_schema_validity_existing_exposure_yml_valid(
 
 
 @pytest.mark.skip_targets(["spark"])
+@pytest.mark.skip_for_dbt_fusion
 def test_exposure_schema_validity_no_exposures(test_id: str, dbt_project: DbtProject):
     test_result = dbt_project.test(test_id, DBT_TEST_NAME)
     assert test_result["status"] == "pass"
 
 
 # Schema validity currently not supported on ClickHouse
 @pytest.mark.skip_targets(["spark", "clickhouse"])
+@pytest.mark.skip_for_dbt_fusion
 def test_exposure_schema_validity_correct_columns_and_types(
     test_id: str, dbt_project: DbtProject
 ):
@@ -86,6 +90,7 @@ def test_exposure_schema_validity_correct_columns_and_types(
 
 
 @pytest.mark.skip_targets(["spark"])
+@pytest.mark.skip_for_dbt_fusion
 def test_exposure_schema_validity_correct_columns_and_invalid_type(
     test_id: str, dbt_project: DbtProject
 ):
@@ -118,6 +123,7 @@ def test_exposure_schema_validity_correct_columns_and_invalid_type(
 
 # Schema validity currently not supported on ClickHouse
 @pytest.mark.skip_targets(["spark", "clickhouse"])
+@pytest.mark.skip_for_dbt_fusion
 def test_exposure_schema_validity_invalid_type_name_present_in_error(
     test_id: str, dbt_project: DbtProject
 ):
@@ -160,6 +166,7 @@ def test_exposure_schema_validity_invalid_type_name_present_in_error(
 
 
 @pytest.mark.skip_targets(["spark"])
+@pytest.mark.skip_for_dbt_fusion
 def test_exposure_schema_validity_correct_columns_and_missing_type(
     test_id: str, dbt_project: DbtProject
 ):
@@ -183,6 +190,7 @@ def test_exposure_schema_validity_correct_columns_and_missing_type(
 
 
 @pytest.mark.skip_targets(["spark"])
+@pytest.mark.skip_for_dbt_fusion
 def test_exposure_schema_validity_missing_columns(
     test_id: str, dbt_project: DbtProject
 ):

integration_tests/tests/test_long_strings.py

@@ -1,3 +1,4 @@
+import pytest
 from dbt_project import DbtProject
 
 SAFE_QUERY_SIZE = 10000
@@ -17,6 +18,7 @@ def read_run_result(dbt_project, test_id):
     )[0]
 
 
+@pytest.mark.skip_for_dbt_fusion
 def test_query_size_exceed(test_id: str, dbt_project: DbtProject):
     dbt_project.dbt_runner.vars["disable_run_results"] = False
     max_query_size = int(
@@ -35,6 +37,7 @@ def test_query_size_exceed(test_id: str, dbt_project: DbtProject):
         assert len(result["compiled_code"]) < max_query_size
 
 
+@pytest.mark.skip_for_dbt_fusion
 def test_query_size_safe(test_id: str, dbt_project: DbtProject):
     dbt_project.dbt_runner.vars["disable_run_results"] = False
     query = generate_query(SAFE_QUERY_SIZE)