Skip to content

Commit

Permalink
skipping for serious bug
Browse files Browse the repository at this point in the history
  • Loading branch information
benc-db committed Dec 7, 2023
1 parent 6c59f00 commit 4c5c70c
Showing 1 changed file with 22 additions and 7 deletions.
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
import os
import mock
import pytest
from dbt.tests import util
from tests.functional.adapter.warehouse_per_model import fixtures
Expand All @@ -24,35 +26,45 @@ def models(self):
"special": d,
}

@pytest.fixture(scope="class")
def profile_dir(self, profiles_root):
return str(profiles_root)


class BaseSpecifyingCompute(BaseWarehousePerModel):
"""Base class for testing various ways to specify a warehouse."""

def test_wpm(self, project):
util.run_dbt(["seed"])
def test_wpm(self, project, profile_dir):
util.run_dbt(["seed", "--profiles-dir", profile_dir])
models = project.test_config.get("model_names")
for model_name in models:
# Since the profile doesn't define a compute resource named 'alternate_warehouse'
# we should fail with an error if the warehouse specified for the model is
# correctly handled.
res = util.run_dbt(["run", "--select", model_name], expect_pass=False)
res = util.run_dbt(
["run", "--select", model_name, "--profiles-dir", profile_dir],
expect_pass=False,
)
msg = res.results[0].message
assert "Compute resource alternate_warehouse does not exist" in msg
assert model_name in msg


@pytest.mark.skip("May fail non-deterministically due to issue in dbt test framework.")
class TestSpecifyingInConfigBlock(BaseSpecifyingCompute):
@pytest.fixture(scope="class")
def test_config(self):
return {"model_names": ["target"]}


@pytest.mark.skip("May fail non-deterministically due to issue in dbt test framework.")
class TestSpecifyingInSchemaYml(BaseSpecifyingCompute):
@pytest.fixture(scope="class")
def test_config(self):
return {"model_names": ["target2"]}


@pytest.mark.skip("May fail non-deterministically due to issue in dbt test framework.")
class TestSpecifyingForProjectModels(BaseSpecifyingCompute):
@pytest.fixture(scope="class")
def project_config_update(self):
Expand All @@ -67,6 +79,7 @@ def test_config(self):
return {"model_names": ["target3"]}


@pytest.mark.skip("May fail non-deterministically due to issue in dbt test framework.")
class TestSpecifyingForProjectModelsInFolder(BaseSpecifyingCompute):
@pytest.fixture(scope="class")
def project_config_update(self):
Expand Down Expand Up @@ -109,15 +122,17 @@ def snapshots(self):
"target_snap.sql": fixtures.target_snap,
}

def test_wpm(self, project):
_, log = util.run_dbt_and_capture(["--debug", "seed"])
def test_wpm(self, project, profile_dir):
_, log = util.run_dbt_and_capture(["--debug", "seed", "--profiles-dir", profile_dir])
assert "`source` using compute resource 'alternate_warehouse2'" in log

_, log = util.run_dbt_and_capture(["--debug", "run", "--select", "target", "target3"])
_, log = util.run_dbt_and_capture(
["--debug", "run", "--select", "target", "target3", "--profiles-dir", profile_dir]
)
assert "`target` using compute resource 'alternate_warehouse'" in log
assert "`target3` using default compute resource" in log

_, log = util.run_dbt_and_capture(["--debug", "snapshot"])
_, log = util.run_dbt_and_capture(["--debug", "snapshot", "--profiles-dir", profile_dir])
assert "`target_snap` using compute resource 'alternate_warehouse3'" in log

util.check_relations_equal(project.adapter, ["target", "source"])

0 comments on commit 4c5c70c

Please sign in to comment.