How to find the start date and end date of a particular task in dag in airflow?

Question

I'm using kwargs['execution_date'] for getting the execution date of dag but it gives the time when the overall dag is invoked, but i need the time where a particular task is started and ended in airflow.

Answer 1

• Use get_task_instance() utility function to obtain a TaskInstance
• From TaskInstance object, you can get start_date & end_date

---

As a sidenote, the context / kwargs do contain end_date & END_DATE (nodash-format), but not start_date

Answer 2

from airflow.api.common.experimental import get_task_instance

execution_date = context['execution_date'] - timedelta(0)
task_instance = get_task_instance.get_task_instance(<dag_id>,<task_id>,execution_date)
start_date = task_instance.start_date
end_date = task_instance.end_date