GitHub user DhavalGojiya added a comment to the discussion:
`dag_run.get_task_instances` alternative in airflow 3
> Awesome, thanks. How could we get the complete task instances objects ? not
> just the states, I want to read values like `map_index`, `start_date`,
> `try_number`, `max_tries`, etc.
```python
from airflow.models import TaskInstance
dag_run = context["dag_run"]
task1 = TaskInstance.get_task_instance(dag_id=dag_run.dag_id,
run_id=dag_run.run_id, task_id="fetch_data", map_index=-1)
task2 = TaskInstance.get_task_instance(dag_id=dag_run.dag_id,
run_id=dag_run.run_id, task_id="deduplicate_data", map_index=-1)
task3 = TaskInstance.get_task_instance(dag_id=dag_run.dag_id,
run_id=dag_run.run_id, task_id="store_data", map_index=-1)
# Now
(Pdb) task1.map_index
-1
(Pdb) task1.start_date
datetime.datetime(2026, 3, 2, 7, 31, 55, 578895, tzinfo=Timezone('UTC'))
(Pdb) task1.try_number
1
(Pdb) task1.max_tries
2
```
`map_index` argument is required in `TaskInstance.get_task_instance` function
call. Don't know what that mean but this is works for me.
GitHub link:
https://github.com/apache/airflow/discussions/56726#discussioncomment-15968524
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
