Sum over gathered

python_modules/dagster/dagster/_core/definitions/declarative_automation/automation_condition_evaluator.py

@@ -124,9 +124,7 @@ async def async_evaluate(
         num_conditions = len(self.entity_keys)
         num_evaluated = 0
 
-        async def _evaluate_entity_async(entity_key: EntityKey) -> None:
-            nonlocal num_evaluated
-
+        async def _evaluate_entity_async(entity_key: EntityKey) -> int:
             self.logger.debug(
                 f"Evaluating {entity_key.to_user_string()} ({num_evaluated+1}/{num_conditions})"
             )
@@ -150,15 +148,16 @@ async def _evaluate_entity_async(entity_key: EntityKey) -> None:
                 f"requested ({requested_str}) "
                 f"({format(result.end_timestamp - result.start_timestamp, '.3f')} seconds)"
             )
-            num_evaluated += 1
+            return 1
 
         for topo_level in self.asset_graph.toposorted_entity_keys_by_level:
             coroutines = [
                 _evaluate_entity_async(entity_key)
                 for entity_key in topo_level
                 if entity_key in self.entity_keys
             ]
-            await asyncio.gather(*coroutines)
+            gathered = await asyncio.gather(*coroutines)
+            num_evaluated += sum(gathered)
 
         return list(self.current_results_by_key.values()), list(self._get_entity_subsets())