diff --git a/warehouse/dbt/models/intermediate/events/int_events.sql b/warehouse/dbt/models/intermediate/events/int_events.sql index f71cc3b2a..538d249f3 100644 --- a/warehouse/dbt/models/intermediate/events/int_events.sql +++ b/warehouse/dbt/models/intermediate/events/int_events.sql @@ -28,6 +28,9 @@ "field": "time", "data_type": "timestamp", "granularity": "day", + }, + meta={ + 'sync_to_db': True } ) }} diff --git a/warehouse/oso_dagster/assets/clickhouse_dbt_marts.py b/warehouse/oso_dagster/assets/clickhouse_dbt_marts.py index fe9eab1c7..6bef9e0c0 100644 --- a/warehouse/oso_dagster/assets/clickhouse_dbt_marts.py +++ b/warehouse/oso_dagster/assets/clickhouse_dbt_marts.py @@ -14,6 +14,7 @@ from ..utils.common import SourceMode MART_DIRECTORY = "marts" +INTERMEDIATE_DIRECTORY = "intermediate" SYNC_KEY = "sync_to_db" @@ -51,6 +52,13 @@ def clickhouse_assets_from_manifests_map( nodes = manifest["nodes"].values() # Get manifests of mart models to copy marts = list(filter(lambda n: MART_DIRECTORY in n.get("fqn"), nodes)) + + # TEMPORARY HACKY CHANGE TO GET INT_EVENTS COPIED TO CLICKHOUSE + intermediates = list( + filter(lambda n: INTERMEDIATE_DIRECTORY in n.get("fqn"), nodes) + ) + marts.extend(intermediates) + copied_mart_names: List[str] = [] skipped_mart_names: List[str] = [] result = AssetFactoryResponse([])