Skip to content

Commit

Permalink
add a skip marker indicating the issue that needs to be resolved
Browse files Browse the repository at this point in the history
  • Loading branch information
mikealfare committed Sep 22, 2023
1 parent b9f9209 commit d41cb38
Showing 1 changed file with 12 additions and 6 deletions.
18 changes: 12 additions & 6 deletions tests/functional/adapter/test_persist_test_results.py
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
from typing import Dict

import pytest

from dbt.tests.adapter.persist_test_results.basic import PersistTestResults
Expand All @@ -8,11 +10,15 @@ class TestPersistTestResultsDatabricks(PersistTestResults):
pass


@pytest.mark.skip("Spark handles delete differently and this is not yet accounted for.")
@pytest.mark.skip_profile("spark_session", "databricks_cluster", "databricks_sql_endpoint")
class TestPersistTestResultsSpark(PersistTestResults):
@pytest.fixture(scope="class")
def project_config_update(self):
return {
"seeds": {"quote_columns": True},
"tests": {"+schema": self.audit_schema_suffix},
}
def delete_record(self, project, record: Dict[str, str]):
"""
Using "DELETE FROM" with Spark throws the following error:
dbt.exceptions.DbtDatabaseError: Database Error
org.apache.hive.service.cli.HiveSQLException:
Error running query: org.apache.spark.sql.AnalysisException:
DELETE is only supported with v2 tables.
"""
pass

0 comments on commit d41cb38

Please sign in to comment.