This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new ee7f66729be Do not print error code at output when runnign uv symc for
dep check (#52742)
ee7f66729be is described below
commit ee7f66729be312805efd7edba596cf4e5bb1cea0
Author: Jarek Potiuk <[email protected]>
AuthorDate: Wed Jul 2 22:47:30 2025 +0200
Do not print error code at output when runnign uv symc for dep check
(#52742)
---
.../src/airflow_breeze/utils/constraints_version_check.py | 2 ++
.../src/airflow_breeze/utils/docker_command_utils.py | 15 +++++++++++----
2 files changed, 13 insertions(+), 4 deletions(-)
diff --git a/dev/breeze/src/airflow_breeze/utils/constraints_version_check.py
b/dev/breeze/src/airflow_breeze/utils/constraints_version_check.py
index c72556d7f39..4077cf1b417 100755
--- a/dev/breeze/src/airflow_breeze/utils/constraints_version_check.py
+++ b/dev/breeze/src/airflow_breeze/utils/constraints_version_check.py
@@ -478,6 +478,7 @@ def explain_package_upgrade(
]
),
output=output_before,
+ signal_error=False,
)
update_pyproject_dependency(airflow_pyproject, pkg, latest_version)
if get_verbose():
@@ -502,6 +503,7 @@ def explain_package_upgrade(
],
),
output=output_after,
+ signal_error=False,
)
if after_result.returncode == 0:
explanation += f"\n[bold yellow]Package {pkg} can be upgraded from
{pinned_version} to {latest_version} without conflicts.[/]."
diff --git a/dev/breeze/src/airflow_breeze/utils/docker_command_utils.py
b/dev/breeze/src/airflow_breeze/utils/docker_command_utils.py
index 80772a6ec84..ed9e9dd7a2f 100644
--- a/dev/breeze/src/airflow_breeze/utils/docker_command_utils.py
+++ b/dev/breeze/src/airflow_breeze/utils/docker_command_utils.py
@@ -724,7 +724,11 @@ def bring_compose_project_down(preserve_volumes: bool,
shell_params: ShellParams
def execute_command_in_shell(
- shell_params: ShellParams, project_name: str, command: str | None = None,
output: Output | None = None
+ shell_params: ShellParams,
+ project_name: str,
+ command: str | None = None,
+ output: Output | None = None,
+ signal_error: bool = True,
) -> RunCommandResult:
"""Executes command in shell.
@@ -765,10 +769,12 @@ def execute_command_in_shell(
shell_params.extra_args = (command,)
if get_verbose():
get_console().print(f"[info]Command to execute: '{command}'[/]")
- return enter_shell(shell_params, output=output)
+ return enter_shell(shell_params, output=output, signal_error=signal_error)
-def enter_shell(shell_params: ShellParams, output: Output | None = None) ->
RunCommandResult:
+def enter_shell(
+ shell_params: ShellParams, output: Output | None = None, signal_error:
bool = True
+) -> RunCommandResult:
"""
Executes entering shell using the parameters passed as kwargs:
@@ -838,7 +844,8 @@ def enter_shell(shell_params: ShellParams, output: Output |
None = None) -> RunC
)
if command_result.returncode == 0:
return command_result
- get_console().print(f"[red]Error {command_result.returncode} returned[/]")
+ if signal_error:
+ get_console().print(f"[red]Error {command_result.returncode}
returned[/]")
if get_verbose():
get_console().print(command_result.stderr)
notify_on_unhealthy_backend_container(shell_params.project_name,
shell_params.backend, output)