scheduler orchestration optimization 1 (#381)

* fix scheduler concurrency and orchestration

* remove comment

* add

* resolve comments

* fix

* remove print

Author: mayinghan

eval_protocol/pytest/default_single_turn_rollout_process.py

@@ -39,7 +39,7 @@ def __call__(self, rows: List[EvaluationRow], config: RolloutProcessorConfig) ->
         async def process_row(row: EvaluationRow) -> EvaluationRow:
             """Process a single row asynchronously."""
             start_time = time.perf_counter()
-
+ 
             if len(row.messages) == 0:
                 raise ValueError("Messages is empty. Please provide a non-empty dataset")