code: def _prepare_disk_queue(*, exp_path, last_ack_version):
      exp_path.mkdir(parents=True)
      queue = DiskQueue(
          dir_path=exp_path,
          to_dict=lambda x: x,
          from_dict=lambda x: x,
          lock=threading.RLock(),
      )
      queue.put("op-0")
      queue.put("op-1")
      queue.put("op-2")
  
      SyncOffsetFile(exp_path / "last_put_version").write(3)
      if last_ack_version is not None:
          SyncOffsetFile(exp_path / "last_ack_version").write(
              last_ack_version
          )
  
file_path: neptune-client/tests/unit/neptune/new/cli/utils.py
imports: import threading
  from pathlib import Path
  from typing import Optional
  from neptune.cli.utils import get_qualified_name
  from neptune.constants import ASYNC_DIRECTORY, OFFLINE_DIRECTORY
  from neptune.exceptions import MetadataContainerNotFound
  from neptune.internal.backends.api_model import ApiExperiment
  from neptune.internal.container_type import ContainerType
  from neptune.internal.disk_queue import DiskQueue
  from neptune.internal.utils.sync_offset_file import SyncOffsetFile
  from tests.unit.neptune.new.utils.api_experiments_factory import api_metadata_container, api_run
label_desc: Use image node_id 3 for calling a global function with example usage: _prepare_disk_queue() without return types