Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
11 changes: 11 additions & 0 deletions scripts/execution_report_heartbeat.py
Original file line number Diff line number Diff line change
Expand Up @@ -567,6 +567,17 @@ def _is_accepted_report(payload: dict[str, Any]) -> tuple[bool, str]:
return False, notification_failure
if status_key in reject_statuses or stage_key in reject_stages:
return False, f"rejected status={status or '-'} stage={stage or '-'}"
summary = payload.get("summary")
execution_status = str(
(summary.get("execution_status") if isinstance(summary, dict) else None)
or payload.get("execution_status")
or ""
).strip().lower()
if (
execution_status in {"blocked", "error", "failed", "failure"}
or execution_status.endswith("_blocked")
):
return False, "rejected inner execution status"
if status_key and status_key in accepted_statuses:
return True, f"status={status}"
if stage_key and stage_key in accepted_stages:
Expand Down
Loading