class_docstr: Thread to continuously read from the queue and fetch the files
class_docstr_tok: ["Thread","to","continuously","read","from","the","queue","and","fetch","the","files"]
code: def run(self) -> None:
      while True:
          try:
              filepath = self._work_queue.get(block=True)
              self._fetcher._fetch(filepath, self._new_file_callback)
          except Exception as e:
              logger.warning(
                  f"Timeout fetching TensorBoard files from {self._fetcher}. Error: {e}"
                  f" (retrying)...",
                  exc_info=True,
              )
              # Put the failed filepath back onto the list
              if filepath:
                  self._work_queue.put(filepath, block=True)
  
imports: import json
  import logging
  import os
  import queue
  import subprocess
  import sys
  import tempfile
  import threading
  import time
  from typing import Any, Callable, Dict, List
  import boto3
  import requests
  from packaging import version
  import determined
  import determined.common
  from determined.tensorboard import fetchers
label_desc: Use image node_id 2 for calling the TBFetchThread obj's underlying member method code with example usage: obj.run() without return types