code: def run_update_points_in_background(
      peer_url,
      collection_name,
      init_offset=0,
      throttle=False,
      duration=None,
  ):
      p = multiprocessing.Process(
          target=update_points_in_loop,
          args=(
              peer_url,
              collection_name,
              init_offset,
              throttle,
              duration,
          ),
      )
      p.start()
      return p
  
file_path: qdrant/tests/consensus_tests/test_shard_snapshot_transfer_cancel.py
imports: import multiprocessing
  import pathlib
  from time import sleep
  from .fixtures import upsert_random_points, create_collection
  from .utils import *
label_desc: Use image node_id 2 for calling a global function with example usage: run_update_points_in_background(peer_url, collection_name, init_offset, throttle, duration) and returns: p