code: def prep_pause(ft, ops):
      batch_prep1 = [ops.op(size=100) for _ in range(2)]
      batch_prep2 = [ops.op(size=100)]
  
      for op in batch_prep1:
          ft.add(op)
          assert ft.state == State.FORWARDING
      assert batch_prep1 == ft.written
      assert batch_prep1 == ft.forwarded_ops
  
      for op in batch_prep2:
          ft.add(op)
          assert ft.state == State.PAUSING
      assert batch_prep2 == ft.written
      assert batch_prep2 == ft.forwarded_ops
  
imports: import json
  import time
  from dataclasses import dataclass
  from enum import Enum
  import pytest
  from wandb.proto import wandb_internal_pb2
  from wandb.sdk.internal import flow_control, settings_static
  from wandb.sdk.lib import proto_util
  from wandb.sdk.wandb_settings import Settings
label_desc: Use image node_id 4 for calling a global function with example usage: prep_pause(ft, ops) without return types