Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 2 additions & 9 deletions tests/functional/adapter/streaming_tables/test_st_basic.py
Original file line number Diff line number Diff line change
Expand Up @@ -331,17 +331,10 @@ def liquid_clustered_st(self, project) -> BaseRelation:
type=DatabricksRelationType.StreamingTable,
)

@pytest.fixture(scope="class", autouse=True)
def setup(self, project, liquid_clustered_st):
util.run_dbt(["seed"])
util.run_dbt(["run", "--models", liquid_clustered_st.identifier, "--full-refresh"])

yield

project.run_sql(f"drop schema if exists {project.test_schema} cascade")

@sd-db sd-db May 2, 2026

Copy link
Copy Markdown
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

note: skipped the cleanup as this is already handed by the parent class (dbt-core/core/dbt/tests/fixtures/project.py)


def test_liquid_clustering_change_is_applied(self, project, liquid_clustered_st):
"""Changing liquid_clustered_by on an existing ST should apply via ALTER."""
util.run_dbt(["seed"])
util.run_dbt(["run", "--models", liquid_clustered_st.identifier, "--full-refresh"])
util.write_file(fixtures.liquid_clustered_st_schema_v2, "models", "schema.yml")
util.run_dbt(["run", "--models", liquid_clustered_st.identifier])

Expand Down
Loading