code: def open(self) -> None:
      self._ds = datastore.DataStore()
      self._ds.open_for_write(self._settings.sync_file)
      self._flow_control = flow_control.FlowControl(
          settings=self._settings,
          write_record=self._write_record,
          forward_record=self._forward_record,
          pause_marker=self._pause_marker,
          recover_records=self._recover_records,
      )
  
imports: import logging
  from typing import TYPE_CHECKING, Callable, Optional
  from wandb.proto import wandb_internal_pb2
  from wandb.proto import wandb_telemetry_pb2
  from ..interface.interface_queue import InterfaceQueue
  from ..lib import proto_util, telemetry, tracelog
  from .None import context, datastore, flow_control
  from .settings_static import SettingsStatic
label_desc: Use image node_id 2 for calling the WriteManager obj's underlying member method code with example usage: obj.open() without return types