-
Notifications
You must be signed in to change notification settings - Fork 16.4k
feat: Add fail_when_dag_is_paused param to TriggerDagRunOperator #48214
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
Lee-W
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
over all looks good. left some nits
providers/standard/src/airflow/providers/standard/operators/trigger_dagrun.py
Outdated
Show resolved
Hide resolved
providers/standard/src/airflow/providers/standard/operators/trigger_dagrun.py
Outdated
Show resolved
Hide resolved
2522875 to
91187d3
Compare
Lee-W
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
A few wording nitpicks, but in general looks good 🙂
providers/standard/tests/unit/standard/operators/test_trigger_dagrun.py
Outdated
Show resolved
Hide resolved
6350cd5 to
f90e666
Compare
|
@Lee-W thanks for the review. Who can I ask to help with merging these changes in? |
|
I'll keep it open for one or two days in case someone else wants to take a look. After that, I'll merge it |
providers/standard/src/airflow/providers/standard/operators/trigger_dagrun.py
Show resolved
Hide resolved
|
@Lee-W you ok with merging this one? Do you see any issues? |
|
cc @eladkal |
LGTM on my end. minor issue. non-blocking |
Add an optional parameter to
TriggerDagRunOperatorto allow it to check if the triggered DAG is in a Paused state, and if so then fail the task.