def run_replay(self):
        """
            Launches the replay process.
            Replay collects experience from agents
            and serve them to learner
        """
        loadbalancer = self.run_component('replay_loadbalancer')
        components = [loadbalancer]
        for replay_id in range(self.learner_config.replay.replay_shards):
            component_name = 'replay_worker-{}'.format(replay_id)
            replay = self.run_component(component_name)
            components.append(replay)
        U.wait_for_popen(components)

            Launches the replay process.
            Replay collects experience from agents
            and serve them to learner
        
surreal/launch/launcher.py