Hi experts,
I am running the TriggerDagRunOperator example that comes with Airflow.
example_trigger_controller_dag
example_trigger_target_dag
I've created 2 new dags when are based on the above controller and trigger dags.
when I run the example_trigger_controller_dag, i see that the
examle_trigger_target_dag is scheduled to run after a few hours later, how to
schedule it to run immediately?
here is the logs where the Sub task that is scheduled to run at 17:53:31 and
the Base task has ran at 13:53:31.
[2017-10-02 13:53:31,624] {base_task_runner.py:95} INFO - Subtask: [2017-10-02
13:53:31,623] {dagrun_operator.py:74} INFO - Creating DagRun <DagRun
Trigger_Target_Dag @ 2017-10-02 17:53:31: trig__2017-10-02T13:53:31.248671,
externally triggered: True>
I might me doing something really stupid here.
please help.
Thanks
-Sai.
