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

Reply via email to