Skip to content

Commit 7efef2e

Browse files
committed
Pass FreshnessThreshold objects instead of dicts
1 parent 9823473 commit 7efef2e

1 file changed

Lines changed: 6 additions & 7 deletions

File tree

sqlmesh/dbt/manifest.py

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -153,18 +153,17 @@ def _load_all(self) -> None:
153153

154154
def _load_sources(self) -> None:
155155
for source in self._manifest.sources.values():
156-
config_source = _config(source)
157-
source_dict = source.to_dict()
158-
159156
# starting in dbt-core 1.9.5, freshness can be set in both source and source config
160-
config_source_freshness = config_source.pop("freshness", None)
161-
source_dict_freshness = source_dict.pop("freshness", None)
162-
freshness = merge_freshness(source_dict_freshness, config_source_freshness)
157+
source_dict = source.to_dict()
158+
source_dict.pop("freshness", None)
159+
config_source = _config(source)
160+
config_source.pop("freshness", None)
161+
freshness = merge_freshness(source.freshness, source.config.freshness)
163162

164163
source_config = SourceConfig(
165164
**config_source,
166165
**source_dict,
167-
freshness=freshness,
166+
freshness=freshness.to_dict() if freshness else None,
168167
)
169168
self._sources_per_package[source.package_name][source_config.config_name] = (
170169
source_config

0 commit comments

Comments
 (0)