code: def __init__(self, high=1000, mid=500, low=250):
      self._record_num = 0
      self._offset = 0
  
      settings_obj = Settings()
      settings = settings_static.SettingsStatic(settings_obj.to_proto())
      fc = flow_control.FlowControl(
          settings=settings,
          write_record=self._write_func,
          forward_record=self._forward_func,
          pause_marker=self._pause_marker_func,
          recover_records=self._recover_func,
          _threshold_bytes_high=high,
          _threshold_bytes_mid=mid,
          _threshold_bytes_low=low,
      )
      self._fc = fc
      self._written = []
      self._forwarded = []
      self._sendmarks = []
      self._recovered = []
  
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 1 to create a new FlowTester object  with example: obj = FlowTester(high, mid, low)