Getting the date of the most recent successful DAG execution
Solution 1:
I've ended up changing the function in the referenced question to use the latest_execution_date, which is a predefined macro in Airflow, as such:
def get_last_dag_run(dag):
last_dag_run = dag.latest_execution_date
if last_dag_run is None:
return '2013-01-01'
else:
return last_dag_run
Seems to be working for me at the moment.