From 9e14c7ad19340ab2e9dd3fd4cdfe578fd67fe1ff Mon Sep 17 00:00:00 2001 From: Iaroslav Zeigerman Date: Thu, 19 Jun 2025 09:30:51 -0700 Subject: [PATCH] Fix: Warn into a console when the run is blocked by environment updates --- sqlmesh/core/context.py | 13 +++++-------- 1 file changed, 5 insertions(+), 8 deletions(-) diff --git a/sqlmesh/core/context.py b/sqlmesh/core/context.py index 7d17b3b863..8d8648f918 100644 --- a/sqlmesh/core/context.py +++ b/sqlmesh/core/context.py @@ -733,11 +733,9 @@ def _block_until_finalized() -> str: raise SQLMeshError(f"Environment '{environment}' was not found.") if environment_state.finalized_ts: return environment_state.plan_id - logger.warning( - "Environment '%s' is being updated by plan '%s'. Retrying in %s seconds...", - environment, - environment_state.plan_id, - self.config.run.environment_check_interval, + self.console.log_warning( + f"Environment '{environment}' is being updated by plan '{environment_state.plan_id}'. " + f"Retrying in {self.config.run.environment_check_interval} seconds..." ) time.sleep(self.config.run.environment_check_interval) raise SQLMeshError( @@ -774,9 +772,8 @@ def _has_environment_changed() -> bool: ) done = True except CircuitBreakerError: - logger.warning( - "Environment '%s' modified while running. Restarting the run...", - environment, + self.console.log_warning( + f"Environment '{environment}' modified while running. Restarting the run..." ) if exit_on_env_update: interrupted = True