reformat

Author: Benny Chen

eval_protocol/execution/pipeline.py

@@ -847,7 +847,9 @@ async def process_with_semaphore_wrapper(sample_idx: int, sample_data: Dict[str,
 
             for i_outer in range(0, len(tasks), batch_size_for_logging):
                 batch_tasks = tasks[i_outer : i_outer + batch_size_for_logging]
-                batch_results_values: List[Union[Exception, Dict[str, Any], List[Dict[str, Any]]]] = await asyncio.gather(*batch_tasks, return_exceptions=True)
+                batch_results_values: List[
+                    Union[Exception, Dict[str, Any], List[Dict[str, Any]]]
+                ] = await asyncio.gather(*batch_tasks, return_exceptions=True)
                 for res_idx, res_or_exc in enumerate(batch_results_values):
                     if isinstance(res_or_exc, Exception):
                         logger.error(

eval_protocol/mcp/simulation_server.py

@@ -394,7 +394,9 @@ def get_default_config(self) -> Dict[str, Any]:
         pass
 
     # Optional hook: some environments need seed at creation time
-    def create_environment_with_seed(self, config: Dict[str, Any], *, seed: Optional[int] = None) -> Tuple[Any, Any, Dict[str, Any]]:
+    def create_environment_with_seed(
+        self, config: Dict[str, Any], *, seed: Optional[int] = None
+    ) -> Tuple[Any, Any, Dict[str, Any]]:
         """Create environment with a seed when required; default falls back to create+reset.
 
         Subclasses can override when the environment requires the seed at construction time.