Feng Zhou created AIRFLOW-3242:
----------------------------------
Summary: execution_date for TriggerDagRunOperator should be based
from Triggering dag
Key: AIRFLOW-3242
URL: https://issues.apache.org/jira/browse/AIRFLOW-3242
Project: Apache Airflow
Issue Type: Bug
Components: DagRun
Affects Versions: 1.10.0, 1.9.0, 1.8.2
Environment: any linux / mac os
Reporter: Feng Zhou
TriggerDagRunOperator should pick up execute_date from context instead just
default to today. This broke back filling logic if TriggerDagRunOperator is
used.
Could simply add one line to address this issue, see red highlighted line below:
def execute(self, context):
....
dr = trigger_dag.create_dagrun(
run_id=dro.run_id,
state=State.RUNNING,
*_{color:#FF0000}execution_date=context['execution_date'],{color}_* ## around
line#70
conf=dro.payload,
external_trigger=True)
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
