code: def consume_queue_data(self, run_id, metrics, tags, params):
      self.batch_count += 1
      if self.batch_count in self.throw_exception_on_batch_number:
          raise MlflowException("Failed to log run data")
      self.received_run_id = run_id
      self.received_metrics.extend(metrics or [])
      self.received_params.extend(params or [])
      self.received_tags.extend(tags or [])
  
imports: import io
  import pickle
  import random
  import threading
  import time
  import uuid
  import pytest
  from mlflow import MlflowException
  from mlflow.entities.metric import Metric
  from mlflow.entities.param import Param
  from mlflow.entities.run_tag import RunTag
  from mlflow.utils.async_logging.async_logging_queue import AsyncLoggingQueue
label_desc: Use image node_id 2 for calling the RunData obj's underlying member method code with example usage: obj.consume_queue_data(run_id, metrics, tags, params) without return types