code: def test_resuming_queue(self, time_mock):
      # given
      time_mock.side_effect = list(range(1234, 1234 + 500))
  
      with TemporaryDirectory() as dirpath:
          queue = DiskQueue[TestDiskQueue.Obj](
              Path(dirpath),
              self._serializer,
              self._deserializer,
              threading.RLock(),
              max_file_size=999,
          )
          for i in range(1, 501):
              obj = TestDiskQueue.Obj(i, str(i))
              queue.put(obj)
          queue.flush()
          version = queue.get_batch(random.randrange(300, 400))[-1].ver
          version_to_ack = version - random.randrange(100, 200)
          queue.ack(version_to_ack)
  
          self.assertTrue(queue._read_file_version > 100)
          self.assertTrue(queue._write_file_version > 450)
          data_files = glob(dirpath + "/data-*.log")
          self.assertTrue(len(data_files) > 10)
          data_files_versions = [
              int(file[len(dirpath + "/data-") : -len(".log")])
              for file in data_files
          ]
          self.assertTrue(
              len(
                  [
                      ver
                      for ver in data_files_versions
                      if ver <= version_to_ack
                  ]
              )
              == 1
          )
          queue.close()
  
          queue = DiskQueue[TestDiskQueue.Obj](
              Path(dirpath),
              self._serializer,
              self._deserializer,
              threading.RLock(),
              max_file_size=200,
          )
          for i in range(version_to_ack + 1, 501):
              obj = TestDiskQueue.Obj(i, str(i))
              self.assertEqual(
                  queue.get(),
                  self.get_queue_element(obj, i, 1234 + i - 1),
              )
  
          queue.close()
  
imports: import json
  import random
  import threading
  import unittest
  from glob import glob
  from pathlib import Path
  from tempfile import TemporaryDirectory
  from typing import Optional
  from unittest.mock import patch
  from neptune.internal.disk_queue import DiskQueue, QueueElement
label_desc: Use image node_id 7 for calling the TestDiskQueue obj's underlying member method code with example usage: obj.test_resuming_queue(time_mock) without return types