6caf721d1c33cf2fe2a18bdc26f25c8be599ff50,rl_coach/architectures/tensorflow_components/shared_variables.py,SharedRunningStats,__init__,#SharedRunningStats#Any#Any#Any#Any#Any#,27

Before Change

                self.create_ops()
        self.pubsub = None
        if pubsub_params:
            self.channel = "channel-srs-{}".format(self.name)
            self.pubsub = get_memory_backend(pubsub_params)
            subscribe_thread = SharedRunningStatsSubscribe(self)
            subscribe_thread.daemon = True
            subscribe_thread.start()

After Change

class TFSharedRunningStats(SharedRunningStats):
    def __init__(self, replicated_device=None, epsilon=1e-2, name="", create_ops=True, pubsub_params=None):
        super().__init__(name=name, pubsub_params=pubsub_params)
        self.sess = None
        self.replicated_device = replicated_device
        self.epsilon = epsilon
        self.ops_were_created = False

Instances