turbaszek commented on a change in pull request #12819:
URL: https://github.com/apache/airflow/pull/12819#discussion_r536429605
##########
File path: airflow/operators/dagrun_operator.py
##########
@@ -144,6 +144,9 @@ def execute(self, context: Dict):
dag = dag_bag.get_dag(self.trigger_dag_id)
dag.clear(start_date=self.execution_date,
end_date=self.execution_date)
+
+ dag_run = DagRun.find(dag_id=dag.dag_id, run_id=run_id)[0]
Review comment:
I'm sorry but I'm not sure if my suggestion was good. We retrieve the
dag run when one already exist. My suggestion would _probably_ work in case of
triggering new one. I think your original suggestion was more ok
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
