Missed one

dagster-io · Oct 11, 2024 · 485dccf · 485dccf
1 parent ea234f1
commit 485dccf
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/.../_core/definitions/declarative_automation/operators/any_downstream_conditions_operator.py b/.../_core/definitions/declarative_automation/operators/any_downstream_conditions_operator.py
@@ -82,7 +82,7 @@ def _get_validated_downstream_conditions(
             if not condition.has_rule_condition
         }
 
-    def evaluate(self, context: AutomationContext[AssetKey]) -> AutomationResult[AssetKey]:
+    async def evaluate(self, context: AutomationContext[AssetKey]) -> AutomationResult[AssetKey]:
         ignored_conditions = self._get_ignored_conditions(context)
         downstream_conditions = self._get_validated_downstream_conditions(
             context.asset_graph.get_downstream_automation_conditions(asset_key=context.key)
@@ -103,7 +103,7 @@ def evaluate(self, context: AutomationContext[AssetKey]) -> AutomationResult[Ass
                 child_index=i,
                 candidate_subset=context.candidate_subset,
             )
-            child_result = child_condition.evaluate(child_context)
+            child_result = await child_context.evaluate_async()
 
             child_results.append(child_result)
             true_subset = true_subset.compute_union(child_result.true_subset)