move batcher

Co-authored-by: thomas <18520168+yaythomas@users.noreply.github.com>

Author: yaythomas

tests/e2e/map_with_concurrent_waits_int_test.py

@@ -173,13 +173,14 @@ def test_map_with_concurrent_waits_api_call_count_scales_with_real_ops_not_empti
                 operation_type=OperationType.STEP,
                 action=OperationAction.START,
             )
-        batcher = ThreadPoolExecutor(max_workers=1)
-        batcher.submit(state.checkpoint_batches_forever)
 
             ev = CompletionEvent()
             completion_events.append(ev)
             state._checkpoint_queue.put(QueuedOperation(op, ev))  # noqa: SLF001
 
+        batcher = ThreadPoolExecutor(max_workers=1)
+        batcher.submit(state.checkpoint_batches_forever)
+        
         # Wait for all 410 to be processed
         for ev in completion_events:
             ev.wait()