br413 commented on code in PR #70171:
URL: https://github.com/apache/airflow/pull/70171#discussion_r3911672790
##########
providers/dbt/cloud/src/airflow/providers/dbt/cloud/hooks/dbt.py:
##########
@@ -825,6 +825,62 @@ def get_job_run_status(self, run_id: int, account_id: int
| None = None) -> int:
return job_run_status
+ @staticmethod
+ def _format_run_step_failure(step: dict[str, Any]) -> str:
+ details = [f"step {step.get('index')}: {step.get('name',
'<unknown>')}"]
+ if status_humanized := step.get("status_humanized"):
+ details.append(f"status={status_humanized}")
+ elif status := step.get("status"):
+ details.append(f"status_code={status}")
+ for field in ("status_message", "log", "logs", "debug_logs"):
+ if value := step.get(field):
+ details.append(f"{field}={value}")
+ return " | ".join(details)
+
+ @fallback_to_default_account
Review Comment:
Good catch — removed the decorator in 6a95ab59f7.
\log_job_run_failure_details\ only uses \ccount_id\ when it calls
\get_job_run\, which already has \@fallback_to_default_account\. Callers are
also downstream of status polling paths that resolved the account earlier.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
