This is an automated email from the ASF dual-hosted git repository.
amoghdesai pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 1c59cedd8ae Fix the taskflow context example in docs (#49399)
1c59cedd8ae is described below
commit 1c59cedd8aecd443ee9a4bd10e219d96f6679623
Author: Amogh Desai <[email protected]>
AuthorDate: Thu Apr 17 19:14:00 2025 +0530
Fix the taskflow context example in docs (#49399)
---
devel-common/src/docs/shared/template-examples/taskflow.rst | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/devel-common/src/docs/shared/template-examples/taskflow.rst
b/devel-common/src/docs/shared/template-examples/taskflow.rst
index 5ea69554518..ee5251ba256 100644
--- a/devel-common/src/docs/shared/template-examples/taskflow.rst
+++ b/devel-common/src/docs/shared/template-examples/taskflow.rst
@@ -22,7 +22,7 @@
@task
- def print_ti_info(task_instance: TaskInstance | None = None, dag_run:
DagRun | None = None):
+ def print_ti_info(task_instance: TaskInstance, dag_run: DagRun):
print(f"Run ID: {task_instance.run_id}") # Run ID:
scheduled__2023-08-09T00:00:00+00:00
print(f"Duration: {task_instance.duration}") # Duration: 0.972019
print(f"DAG Run queued at: {dag_run.queued_at}") # 2023-08-10
00:00:01+02:20
