Hi Devs,
I was reviewing DAG class and noticed that almost all it's methods are
public.
So, one can do something like below:
with DAG(...)as dag:
t1 = BashOperator(...)
run_id = DagRun.generate_run_id(DagRunType.MANUAL, datetime.utcnow())
# This one works OK and create a DagRun for the Scheduler to pick up
dag.create_dagrun(state=DagRunState.QUEUED, run_id=run_id)
# OR EVEN DO BELOW - which caused my laptop to run on 100% CPU
#dag.run()
And I was wondering if this is intentional and/or expected behavior?
Thanks,
Khalid