Skip to content

Commit 15a0e10

Browse files
authored
fix: include forward_only parsed snapshot (#5442)
1 parent 92e4a32 commit 15a0e10

File tree

1 file changed

+9
-2
lines changed

1 file changed

+9
-2
lines changed

sqlmesh/core/state_sync/db/migrator.py

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -229,6 +229,7 @@ def _migrate_snapshot_rows(
229229
"updated_ts": updated_ts,
230230
"unpaused_ts": unpaused_ts,
231231
"unrestorable": unrestorable,
232+
"forward_only": forward_only,
232233
}
233234
for where in (
234235
snapshot_id_filter(
@@ -237,10 +238,16 @@ def _migrate_snapshot_rows(
237238
if snapshots is not None
238239
else [None]
239240
)
240-
for name, identifier, raw_snapshot, updated_ts, unpaused_ts, unrestorable in fetchall(
241+
for name, identifier, raw_snapshot, updated_ts, unpaused_ts, unrestorable, forward_only in fetchall(
241242
self.engine_adapter,
242243
exp.select(
243-
"name", "identifier", "snapshot", "updated_ts", "unpaused_ts", "unrestorable"
244+
"name",
245+
"identifier",
246+
"snapshot",
247+
"updated_ts",
248+
"unpaused_ts",
249+
"unrestorable",
250+
"forward_only",
244251
)
245252
.from_(self.snapshot_state.snapshots_table)
246253
.where(where)

0 commit comments

Comments
 (0)