This is an automated email from the ASF dual-hosted git repository.
jscheffl 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 b41b11d3fc1 Avoid false recovery alerts when failed job lookup fails
(#64863)
b41b11d3fc1 is described below
commit b41b11d3fc18c23c40703808432f368c321887fe
Author: Henry Chen <[email protected]>
AuthorDate: Sun Apr 19 04:57:58 2026 +0800
Avoid false recovery alerts when failed job lookup fails (#64863)
* CI: Avoid false recovery alerts when failed job lookup fails
* Potential fix for pull request finding
Co-authored-by: Copilot Autofix powered by AI
<[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()]
