code: def __init__(self, name="", pubsub_params=None):
      self.name = name
      self.pubsub = None
      if pubsub_params:
          self.channel = "channel-srs-{}".format(self.name)
          from rl_coach.memories.backend.memory_impl import (
              get_memory_backend,
          )
  
          self.pubsub = get_memory_backend(pubsub_params)
          subscribe_thread = SharedRunningStatsSubscribe(self)
          subscribe_thread.daemon = True
          subscribe_thread.start()
  
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 SharedRunningStats object from inherited base classes: ABC with example: obj = SharedRunningStats(name, pubsub_params)