Skip to content

Commit

Permalink
Try adding iceberg incremental model scenarios.
Browse files Browse the repository at this point in the history
  • Loading branch information
VersusFacit committed Sep 26, 2024
1 parent 47f6595 commit 0c70786
Show file tree
Hide file tree
Showing 2 changed files with 22 additions and 0 deletions.
20 changes: 20 additions & 0 deletions tests/functional/relation_tests/models.py
Original file line number Diff line number Diff line change
Expand Up @@ -45,3 +45,23 @@
) }}
select * from {{ ref('my_seed') }}
"""

ICEBERG_TABLE = """
{{ config(
materialized='table',
table_format="iceberg",
external_volume="s3_iceberg_snow",
) }}
select * from {{ ref('my_seed') }}
"""

ICEBERG_INCREMENTAL_TABLE = """
{{ config(
materialized='incremental',
table_format='iceberg',
incremental_strategy='append',
unique_key="id",
external_volume = "s3_iceberg_snow",
) }}
select * from {{ ref('my_seed') }}
"""
2 changes: 2 additions & 0 deletions tests/functional/relation_tests/test_relation_type_change.py
Original file line number Diff line number Diff line change
Expand Up @@ -42,6 +42,8 @@ def error_message(self) -> str:
Model(models.TABLE, "table", "default"),
Model(models.DYNAMIC_TABLE, "dynamic_table", "default"),
Model(models.DYNAMIC_ICEBERG_TABLE, "dynamic_table", "iceberg"),
Model(models.ICEBERG_TABLE, "table", "iceberg"),
Model(models.ICEBERG_INCREMENTAL_TABLE, "incremental", "iceberg"),
]
scenarios = [Scenario(*scenario) for scenario in product(relations, relations)]

Expand Down

0 comments on commit 0c70786

Please sign in to comment.