Skip to content

Commit

Permalink
Add all_deps_blocking_checks_passed condition
Browse files Browse the repository at this point in the history
  • Loading branch information
OwenKephart committed Oct 10, 2024
1 parent da39e59 commit f8d9617
Showing 1 changed file with 14 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -523,6 +523,20 @@ def any_deps_in_progress() -> "AnyDepsCondition":
"any_deps_in_progress"
)

@experimental
@staticmethod
def all_deps_blocking_checks_passed() -> "AllDepsCondition":
"""Returns an AutomationCondition that is true for any partition where all upstream
blocking checks have passed, or will be requested.
"""
with disable_dagster_warnings():
return AutomationCondition.all_deps_match(
AutomationCondition.all_checks_match(
AutomationCondition.check_passed() | AutomationCondition.will_be_requested(),
blocking_only=True,
).with_label("all_blocking_checks_passed")
).with_label("all_deps_blocking_checks_passed")

@experimental
@staticmethod
def all_deps_updated_since_cron(
Expand Down

0 comments on commit f8d9617

Please sign in to comment.