This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch v3-0-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-0-test by this push:
new 3f7c1b3e1af [v3-0-test] Remove outdated code comments from task runner
(#51782) (#51798)
3f7c1b3e1af is described below
commit 3f7c1b3e1af5a6b83ad3a18ae982aee2c00f861b
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Jun 16 23:00:34 2025 +0200
[v3-0-test] Remove outdated code comments from task runner (#51782) (#51798)
(cherry picked from commit 0df91d904f74a9c5c141f504b37dfbe348222e8f)
Co-authored-by: Amogh Desai <[email protected]>
---
task-sdk/src/airflow/sdk/execution_time/task_runner.py | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/task-sdk/src/airflow/sdk/execution_time/task_runner.py
b/task-sdk/src/airflow/sdk/execution_time/task_runner.py
index 1f7219a7a8e..9d75a7250e4 100644
--- a/task-sdk/src/airflow/sdk/execution_time/task_runner.py
+++ b/task-sdk/src/airflow/sdk/execution_time/task_runner.py
@@ -283,7 +283,7 @@ class RuntimeTaskInstance(TaskInstance):
task_ids: str | Iterable[str] | None = None,
dag_id: str | None = None,
key: str = "return_value", # TODO: Make this a constant
(``XCOM_RETURN_KEY``)
- include_prior_dates: bool = False, # TODO: Add support for this
+ include_prior_dates: bool = False,
*,
map_indexes: int | Iterable[int] | None | ArgNotSet = NOTSET,
default: Any = None,
@@ -906,8 +906,6 @@ def run(
# If AirflowFailException is raised, task should not retry.
# If a sensor in reschedule mode reaches timeout, task should not
retry.
log.exception("Task failed with exception")
- # TODO: Handle fail_stop here:
https://github.com/apache/airflow/issues/44951
- # TODO: Handle addition to Log table:
https://github.com/apache/airflow/issues/44952
msg = TaskState(
state=TaskInstanceState.FAILED,
end_date=datetime.now(tz=timezone.utc),
