This is an automated email from the ASF dual-hosted git repository.
vatsrahul1001 pushed a commit to branch v3-2-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit c645225fce897121e1c08e5a8f5e721256cbd953
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat Apr 18 23:00:52 2026 +0200
[v3-2-test] Avoid false recovery alerts when failed job lookup fails
(#64863) (#65473)
* CI: Avoid false recovery alerts when failed job lookup fails
* Potential fix for pull request finding
---------
(cherry picked from commit b41b11d3fc18c23c40703808432f368c321887fe)
Co-authored-by: Henry Chen <[email protected]>
Co-authored-by: Copilot Autofix powered by AI
<[email protected]>
---
dev/breeze/src/airflow_breeze/utils/workflow_status.py | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
diff --git a/dev/breeze/src/airflow_breeze/utils/workflow_status.py
b/dev/breeze/src/airflow_breeze/utils/workflow_status.py
index 6ed3bd55390..912837e09d6 100644
--- a/dev/breeze/src/airflow_breeze/utils/workflow_status.py
+++ b/dev/breeze/src/airflow_breeze/utils/workflow_status.py
@@ -33,6 +33,13 @@ from rich.console import Console
console = Console(width=400, color_system="standard")
+def format_failed_jobs_lookup_error(run_id: int) -> str:
+ return (
+ "ERROR: failed to fetch failed jobs for workflow run "
+ f"{run_id}; inspect it directly with: gh run view {run_id} --json jobs
--repo apache/airflow"
+ )
+
+
def workflow_status(
branch: str,
workflow_id: str,
@@ -93,7 +100,7 @@ def get_failed_jobs(run_id: int) -> list[str]:
)
if result.returncode != 0:
console.print(f"[red]Error fetching failed jobs:
{result.stderr}[/red]")
- return []
+ return [format_failed_jobs_lookup_error(run_id)]
return [line.strip() for line in result.stdout.strip().splitlines() if
line.strip()]
