Skip to content
Open
Changes from 4 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
1 change: 1 addition & 0 deletions task-sdk/src/airflow/sdk/execution_time/supervisor.py
Original file line number Diff line number Diff line change
Expand Up @@ -1680,6 +1680,7 @@ def start( # type: ignore[override]
log = structlog.get_logger(logger_name="task")

state, msg, error = run(ti, context, log)
context["exception"] = error
finalize(ti, state, context, log, error)
Comment thread
ASk1 marked this conversation as resolved.

# In the normal subprocess model, the task runner calls this before exiting.
Expand Down
Loading