class_docstr: Consumes the records from the dataset queue.
class_docstr_tok: ["Consumes","the","records","from","the","dataset","queue","."]
docstr: Runs the consumer.
docstr_tok: ["Runs","the","consumer","."]
code: def run(self):
      """Runs the consumer."""
      while self.running:
          self.log_next_batch()
      self._log_remaining()
  
imports: import atexit
  import logging
  import random
  import threading
  from queue import Empty, Queue
  from typing import Any, Dict, Iterable, List, Optional
  import backoff
  import monotonic
  import wrapt
  from argilla.client.api import Api
  from argilla.client.models import Record
  from argilla.client.sdk.commons.errors import ArApiResponseError
label_desc: Use image node_id 2 for calling the DatasetRecordsConsumer obj's underlying member method code with example usage: obj.run() without return types