-
Notifications
You must be signed in to change notification settings - Fork 1.6k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
9 changed files
with
141 additions
and
19 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
5 changes: 5 additions & 0 deletions
5
test/integration/035_changing_relation_type_test/models/model.sql
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,5 @@ | ||
|
|
||
|
|
||
| {{ config(materialized=var('materialized'), sql_where='TRUE') }} | ||
|
|
||
| select '{{ var("materialized") }}' as materialization |
84 changes: 84 additions & 0 deletions
84
test/integration/035_changing_relation_type_test/test_changing_relation_type.py
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,84 @@ | ||
| from nose.plugins.attrib import attr | ||
| from test.integration.base import DBTIntegrationTest | ||
|
|
||
|
|
||
| class TestChangingRelationType(DBTIntegrationTest): | ||
|
|
||
| @property | ||
| def schema(self): | ||
| return "changing_relation_type_035" | ||
|
|
||
| @staticmethod | ||
| def dir(path): | ||
| return "test/integration/035_changing_relation_type_test/" + path.lstrip("/") | ||
|
|
||
| @property | ||
| def models(self): | ||
| return self.dir("models") | ||
|
|
||
| def swap_types_and_test(self): | ||
| # test that dbt is able to do intelligent things when changing | ||
| # between materializations that create tables and views. | ||
|
|
||
| results = self.run_dbt(['run', '--vars', 'materialized: view']) | ||
| self.assertEquals(results[0].node['config']['materialized'], 'view') | ||
| self.assertEqual(len(results), 1) | ||
|
|
||
| results = self.run_dbt(['run', '--vars', 'materialized: table']) | ||
| self.assertEquals(results[0].node['config']['materialized'], 'table') | ||
| self.assertEqual(len(results), 1) | ||
|
|
||
| results = self.run_dbt(['run', '--vars', 'materialized: view']) | ||
| self.assertEquals(results[0].node['config']['materialized'], 'view') | ||
| self.assertEqual(len(results), 1) | ||
|
|
||
| results = self.run_dbt(['run', '--vars', 'materialized: incremental']) | ||
| self.assertEquals(results[0].node['config']['materialized'], 'incremental') | ||
| self.assertEqual(len(results), 1) | ||
|
|
||
| results = self.run_dbt(['run', '--vars', 'materialized: view']) | ||
| self.assertEquals(results[0].node['config']['materialized'], 'view') | ||
| self.assertEqual(len(results), 1) | ||
|
|
||
| @attr(type="postgres") | ||
| def test__postgres__switch_materialization(self): | ||
| self.use_profile("postgres") | ||
| self.swap_types_and_test() | ||
|
|
||
| @attr(type="snowflake") | ||
| def test__snowflake__switch_materialization(self): | ||
| self.use_profile("snowflake") | ||
| self.swap_types_and_test() | ||
|
|
||
| @attr(type="redshift") | ||
| def test__redshift__switch_materialization(self): | ||
| self.use_profile("redshift") | ||
| self.swap_types_and_test() | ||
|
|
||
| @attr(type="bigquery") | ||
| def test__bigquery__switch_materialization(self): | ||
| # BQ has a weird check that prevents the dropping of tables in the view materialization | ||
| # if --full-refresh is not provided. This is to prevent the clobbering of a date-sharded | ||
| # table with a view if a model config is accidently changed. We should probably remove that check | ||
| # and then remove these bq-specific tests | ||
| self.use_profile("bigquery") | ||
|
|
||
| results = self.run_dbt(['run', '--vars', 'materialized: view']) | ||
| self.assertEquals(results[0].node['config']['materialized'], 'view') | ||
| self.assertEqual(len(results), 1) | ||
|
|
||
| results = self.run_dbt(['run', '--vars', 'materialized: table']) | ||
| self.assertEquals(results[0].node['config']['materialized'], 'table') | ||
| self.assertEqual(len(results), 1) | ||
|
|
||
| results = self.run_dbt(['run', '--vars', 'materialized: view', "--full-refresh"]) | ||
| self.assertEquals(results[0].node['config']['materialized'], 'view') | ||
| self.assertEqual(len(results), 1) | ||
|
|
||
| results = self.run_dbt(['run', '--vars', 'materialized: incremental']) | ||
| self.assertEquals(results[0].node['config']['materialized'], 'incremental') | ||
| self.assertEqual(len(results), 1) | ||
|
|
||
| results = self.run_dbt(['run', '--vars', 'materialized: view', "--full-refresh"]) | ||
| self.assertEquals(results[0].node['config']['materialized'], 'view') | ||
| self.assertEqual(len(results), 1) |