code: def report_stats(self, pool_uid, batch_size, processing_time):
      batch_stats = BatchStats(batch_size, processing_time)
      self.stats_queue.put_nowait((pool_uid, batch_stats))
  
imports: import multiprocessing
  import multiprocessing.pool
  import threading
  from collections import defaultdict
  from itertools import chain
  from queue import SimpleQueue
  from selectors import EVENT_READ, DefaultSelector
  from statistics import mean
  from time import perf_counter
  from typing import Any, Dict, NamedTuple, Optional, Tuple
  import torch
  from prefetch_generator import BackgroundGenerator
  from hivemind.moe.server.module_backend import ModuleBackend
  from hivemind.moe.server.task_pool import TaskPoolBase
  from hivemind.utils import get_logger
label_desc: Use image node_id 3 for calling the StatsReporter obj's underlying member method code with example usage: obj.report_stats(pool_uid, batch_size, processing_time) without return types