diff --git a/sqlmesh/schedulers/airflow/state_sync.py b/sqlmesh/schedulers/airflow/state_sync.py
index 1eb39356bc..345584f6b3 100644
--- a/sqlmesh/schedulers/airflow/state_sync.py
+++ b/sqlmesh/schedulers/airflow/state_sync.py
@@ -325,9 +325,18 @@ def update_auto_restatements(
         )
 
     def get_environment_statements(self, environment: str) -> t.List[EnvironmentStatements]:
-        raise NotImplementedError(
+        """Fetches the environment's statements from the environment_statements table.
+        Args:
+            environment: The environment name
+
+        Returns:
+            A list of the environment statements.
+
+        """
+        logger.warning(
             "Fetching environment statements is not supported by the Airflow state sync."
         )
+        return []
 
     def migrate(
         self,