code: def run(self):
      for message in self.pubsub.listen():
          try:
              obj = pickle.loads(message["data"])
              self.shared_running_stats.push_val(obj)
          except Exception:
              continue
  
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 2 for calling the SharedRunningStatsSubscribe obj's underlying member method code with example usage: obj.run() without return types