Skip to content

Commit 4c42b45

Browse files
authored
Fix: Only include the event_time_filter when rendering a microbatch model (#5333)
1 parent 32407f9 commit 4c42b45

File tree

1 file changed

+13
-11
lines changed

1 file changed

+13
-11
lines changed

sqlmesh/core/renderer.py

Lines changed: 13 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -221,17 +221,19 @@ def _resolve_table(table: str | exp.Table) -> str:
221221
dialect=self._dialect, identify=True, comments=False
222222
)
223223

224-
all_refs = list(
225-
self._jinja_macro_registry.global_objs.get("sources", {}).values() # type: ignore
226-
) + list(
227-
self._jinja_macro_registry.global_objs.get("refs", {}).values() # type: ignore
228-
)
229-
for ref in all_refs:
230-
if ref.event_time_filter:
231-
ref.event_time_filter["start"] = render_kwargs["start_tstz"]
232-
ref.event_time_filter["end"] = to_tstz(
233-
make_ts_exclusive(render_kwargs["end_tstz"], dialect=self._dialect)
234-
)
224+
if self._model and self._model.kind.is_incremental_by_time_range:
225+
all_refs = list(
226+
self._jinja_macro_registry.global_objs.get("sources", {}).values() # type: ignore
227+
) + list(
228+
self._jinja_macro_registry.global_objs.get("refs", {}).values() # type: ignore
229+
)
230+
for ref in all_refs:
231+
if ref.event_time_filter:
232+
ref.event_time_filter["start"] = render_kwargs["start_tstz"]
233+
ref.event_time_filter["end"] = to_tstz(
234+
make_ts_exclusive(render_kwargs["end_tstz"], dialect=self._dialect)
235+
)
236+
235237
jinja_env = self._jinja_macro_registry.build_environment(**jinja_env_kwargs)
236238

237239
expressions = []

0 commit comments

Comments
 (0)