python - 如何使用 TriggerDagRunOperator 触发回填？

Question

我有一个要求，我需要触发的 dagTriggerDagRunOperator来执行回填，而不仅仅是相同的执行日期。

TriggerDagOperator设置如下：

trigger1 = TriggerDagRunOperator(
  task_id = 'trigger1',
  trigger_dag_id = 'target_dag',
  conf = {'message': 'Starting target 1'},
  reset_dag_run = True,
  wait_for_completion = True
)

目标 dag 基本上是：

starting_date = datetime.strptime("2021-11-15", "%Y-%m-%d")

with DAG("target_dag", default_args=default_args, schedule_interval='@daily', max_active_runs=10) as dag:

  start = DummyOperator(
    task_id = 'start'
  )

  t1 = PythonOperator(
    task_id = "t1",
    provide_context=True,
    python_callable=t1
  )

  finish = DummyOperator(
    task_id = 'finish'
  )

  start >> t1 >> finish

target_dag仅在今天执行而不是回填。

无论过去的 dag 运行如何，我如何强制它回填？我正在使用气流 2.0