diff --git a/tests/functional/adapter/simple_snapshot/test_various_configs.py b/tests/functional/adapter/simple_snapshot/test_various_configs.py index 18b82de00..c155c1c96 100644 --- a/tests/functional/adapter/simple_snapshot/test_various_configs.py +++ b/tests/functional/adapter/simple_snapshot/test_various_configs.py @@ -60,7 +60,7 @@ def text_replace(input: str) -> str: invalidate_sql_2 = """ -- invalidate records 11 - 21 update {schema}.snapshot_expected set - test_valid_to = updated_at + interval '1 hour' + TEST_VALID_TO = updated_at + interval '1 hour' where id >= 10 and id <= 20; """ @@ -75,7 +75,7 @@ def text_replace(input: str) -> str: invalidate_multi_key_sql_2 = """ -- invalidate records 11 - 21 update {schema}.snapshot_expected set - test_valid_to = updated_at + interval '1 hour' + TEST_VALID_TO = updated_at + interval '1 hour' where id1 >= 10 and id1 <= 20; """ @@ -129,7 +129,7 @@ def project_config_update(self): "snapshots": { "test": { "+snapshot_meta_column_names": { - "dbt_valid_to": "test_valid_to", + "dbt_valid_to": "TEST_VALID_TO", "dbt_valid_from": "test_valid_from", "dbt_scd_id": "test_scd_id", "dbt_updated_at": "test_updated_at", @@ -175,7 +175,7 @@ def project_config_update(self): "snapshots": { "test": { "+snapshot_meta_column_names": { - "dbt_valid_to": "test_valid_to", + "dbt_valid_to": "TEST_VALID_TO", "dbt_valid_from": "test_valid_from", "dbt_scd_id": "test_scd_id", "dbt_updated_at": "test_updated_at", @@ -195,7 +195,7 @@ def test_snapshot_invalid_column_names(self, project): manifest = get_manifest(project.project_root) snapshot_node = manifest.nodes["snapshot.test.snapshot_actual"] snapshot_node.config.snapshot_meta_column_names == { - "dbt_valid_to": "test_valid_to", + "dbt_valid_to": "TEST_VALID_TO", "dbt_valid_from": "test_valid_from", "dbt_scd_id": "test_scd_id", "dbt_updated_at": "test_updated_at", @@ -210,7 +210,7 @@ def test_snapshot_invalid_column_names(self, project): "snapshots": { "test": { "+snapshot_meta_column_names": { - "dbt_valid_to": "test_valid_to", + "dbt_valid_to": "TEST_VALID_TO", "dbt_updated_at": "test_updated_at", } } @@ -247,7 +247,7 @@ def test_valid_to_current(self, project): original_snapshot: Table = run_sql_with_adapter( project.adapter, - "select id, test_scd_id, test_valid_to from {schema}.snapshot_actual", + "select id, test_scd_id, TEST_VALID_TO from {schema}.snapshot_actual", "all", ) assert original_snapshot[0][2] == datetime.datetime( @@ -269,7 +269,7 @@ def test_valid_to_current(self, project): updated_snapshot: Table = run_sql_with_adapter( project.adapter, - "select id, test_scd_id, test_valid_to from {schema}.snapshot_actual", + "select id, test_scd_id, TEST_VALID_TO from {schema}.snapshot_actual", "all", ) print(updated_snapshot)