shahar1 commented on code in PR #46584:
URL: https://github.com/apache/airflow/pull/46584#discussion_r1948851232
##########
task_sdk/src/airflow/sdk/execution_time/task_runner.py:
##########
@@ -564,7 +565,11 @@ def run(ti: RuntimeTaskInstance, log: Logger) ->
ToSupervisor | None:
msg = early_exit
return msg
- result = _execute_task(context, ti)
+
+ try:
Review Comment:
> Can we handle this at the same level as `except TaskDeferred as defer:` on
L583?
I agree that it looks a bit funny - I did it to avoid duplicating the logic
below the nested `try...except`. I'll wrap it in another function, and then it
might look a bit better.
--
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: commits-unsubscr...@airflow.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
