code: def build_async_operation_processor(
      container_id: UniqueId,
      container_type: ContainerType,
      backend: NeptuneBackend,
      lock: threading.RLock,
      sleep_time: float,
      queue: "Queue[Signal]",
  ) -> OperationProcessor:
      return AsyncOperationProcessor(
          container_id=container_id,
          container_type=container_type,
          backend=backend,
          lock=lock,
          sleep_time=sleep_time,
          batch_size=int(
              os.environ.get(NEPTUNE_ASYNC_BATCH_SIZE) or "1000"
          ),
          queue=queue,
      )
  
file_path: neptune-client/src/neptune/internal/operation_processors/factory.py
imports: import os
  import threading
  from queue import Queue
  from typing import TYPE_CHECKING
  from neptune.envs import NEPTUNE_ASYNC_BATCH_SIZE
  from neptune.internal.backends.neptune_backend import NeptuneBackend
  from neptune.internal.container_type import ContainerType
  from neptune.internal.id_formats import UniqueId
  from neptune.types.mode import Mode
  from .async_operation_processor import AsyncOperationProcessor
  from .offline_operation_processor import OfflineOperationProcessor
  from .operation_processor import OperationProcessor
  from .read_only_operation_processor import ReadOnlyOperationProcessor
  from .sync_operation_processor import SyncOperationProcessor
label_desc: Use image node_id 1 for calling a global function with example usage: build_async_operation_processor(container_id, container_type, backend, lock, sleep_time, queue) and returns: AsyncOperationProcessor