class_docstr: Worker that updates task status in redis with fixed frequency
      
code: def __init__(
      self,
      redis_key: RedisKey,
      ml_task_status: ML_TASK_STATUS,
      db,
      cache,
  ) -> None:
      threading.Thread.__init__(self)
      self.redis_key = redis_key
      self.ml_task_status = ml_task_status
      self.db = db
      self.cache = cache
      self._stop_event = threading.Event()
  
imports: import time
  import pickle
  import socket
  import threading
  from walrus import Database
  from redis.exceptions import ConnectionError
  from mindsdb.utilities.context import context
  from mindsdb.utilities.ml_task_queue.const import ML_TASK_STATUS
label_desc: Use image node_id 1 to create a new StatusNotifier object from inherited base classes: threading with example: obj = StatusNotifier(redis_key, ml_task_status, db, cache)