Fix offset

dagster-io · Oct 22, 2024 · 047f4eb · 047f4eb
1 parent 8219a16
commit 047f4eb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...agster/dagster/_core/definitions/declarative_automation/automation_condition_evaluator.py b/...agster/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)