code: def push(self, x):
      if self.pubsub:
          self.pubsub.redis_connection.publish(
              self.channel, pickle.dumps(x)
          )
          return
  
      self.push_val(x)
  
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 3 for calling the SharedRunningStats obj's underlying member method code with example usage: obj.push(x) without return types