yyhecust opened a new pull request #17302: URL: https://github.com/apache/airflow/pull/17302
In case of existing issue, reference it using one of the following: related: #16961 in backfill function, there are two methods, which are `self._get_dag_run(next_run_date, dag, session=session)` and `self._task_instances_for_dag_run(dag_run, session=session)` in backfill_job.py. In `_get_dag_run` method it use `runs = DagRun.find(dag_id=dag.dag_id, execution_date=run_date, session=session)` to find dagrun, but in `_instances_for_dag_run` it use `dagrun.refresh_from_db` to find dagrun, this method to find dagrun is different from `DagRun.find` so it will cause can not find dagrun when execution_date = 00:00 if set default_timezone=Asia/Shanghai, now I make them the same way to find dagrun, it can backfill successfully. **^ Add meaningful description above** -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
