Skip to content

Commit

Permalink
Fix docstring for TI.fetch_handle_failure_context (#43481)
Browse files Browse the repository at this point in the history
While debugging test failures on #43076, found that
this docstring was wrong, most likely a copy/paste error of `ti._handle_failure`
  • Loading branch information
kaxil authored Oct 29, 2024
1 parent b0a8605 commit 755c10b
Showing 1 changed file with 8 additions and 2 deletions.
10 changes: 8 additions & 2 deletions airflow/models/taskinstance.py
Original file line number Diff line number Diff line change
Expand Up @@ -3187,9 +3187,15 @@ def fetch_handle_failure_context(
fail_stop: bool = False,
):
"""
Handle Failure for the TaskInstance.
Fetch the context needed to handle a failure.
:param fail_stop: if true, stop remaining tasks in dag
:param ti: TaskInstance
:param error: if specified, log the specific exception if thrown
:param test_mode: doesn't record success or failure in the DB if True
:param context: Jinja2 context
:param force_fail: if True, task does not retry
:param session: SQLAlchemy ORM Session
:param fail_stop: if True, fail all downstream tasks
"""
if error:
if isinstance(error, BaseException):
Expand Down

0 comments on commit 755c10b

Please sign in to comment.