diff --git a/sqlmesh/schedulers/airflow/state_sync.py b/sqlmesh/schedulers/airflow/state_sync.py index 897d9b7eb..2b58395ad 100644 --- a/sqlmesh/schedulers/airflow/state_sync.py +++ b/sqlmesh/schedulers/airflow/state_sync.py @@ -236,9 +236,8 @@ def refresh_snapshot_intervals(self, snapshots: t.Collection[Snapshot]) -> t.Lis Returns: The updated snapshots. """ - raise NotImplementedError( - "Refreshing snapshot intervals is not supported by the Airflow state sync." - ) + logger.warning("Refreshing snapshot intervals is not supported by the Airflow state sync") + return list(snapshots) def promote( self,