code: def _write_func(self, record):
      self._record_num += 1
      proto_util._assign_record_num(record, self._record_num)
      self._written.append(record)
      msg_size = OpsFactory.get_op_size(record)
      new_offset = self._offset + msg_size
      self._offset = new_offset
      proto_util._assign_end_offset(record, new_offset)
      return new_offset
  
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 2 for calling the FlowTester obj's underlying member method code with example usage: obj._write_func(record) and returns: new_offset