code: def __init__(self, shared_running_stats):
      super().__init__()
      self.shared_running_stats = shared_running_stats
      self.redis_address = (
          self.shared_running_stats.pubsub.params.redis_address
      )
      self.redis_port = (
          self.shared_running_stats.pubsub.params.redis_port
      )
      self.redis_connection = redis.Redis(
          self.redis_address, self.redis_port
      )
      self.pubsub = self.redis_connection.pubsub()
      self.channel = self.shared_running_stats.channel
      self.pubsub.subscribe(self.channel)
  
imports: import os
  from abc import ABC, abstractmethod
  import threading
  import pickle
  import redis
  import numpy
  from rl_coach.utils import get_latest_checkpoint
label_desc: Use image node_id 1 to create a new SharedRunningStatsSubscribe object from inherited base classes: threading with example: obj = SharedRunningStatsSubscribe(shared_running_stats)