diff --git a/python_modules/dagster/dagster/_core/definitions/declarative_automation/automation_condition_evaluator.py b/python_modules/dagster/dagster/_core/definitions/declarative_automation/automation_condition_evaluator.py index b2ca656e4dbad..51f7c175c4eb6 100644 --- a/python_modules/dagster/dagster/_core/definitions/declarative_automation/automation_condition_evaluator.py +++ b/python_modules/dagster/dagster/_core/definitions/declarative_automation/automation_condition_evaluator.py @@ -139,8 +139,8 @@ async def _evaluate_entity_async(entity_key: EntityKey, offset: int): for topo_level in self.asset_graph.toposorted_entity_keys_by_level: coroutines = [ - _evaluate_entity_async(entity_key, num_evaluated) - for entity_key in topo_level + _evaluate_entity_async(entity_key, offset) + for offset, entity_key in enumerate(topo_level) if entity_key in self.entity_keys ] await asyncio.gather(*coroutines)