def process()

in ppo_ewma/vec_monitor2.py [0:0]

• 18 lines of code
• 6 McCabe index (conditional complexity)

    def process(self):
        lastrews, _obs, firsts = self.env.observe()
        infos = self.env.get_info()
        self.eprets += lastrews
        self.eplens += 1
        for i in range(self.num):
            if firsts[i]:
                timefromstart = round(time.time() - self.tstart, 6)
                ep = Episode(self.eprets[i], self.eplens[i], timefromstart, infos[i])
                if self.ep_buf is not None:
                    self.ep_buf.append(ep)
                if self.per_env_buf is not None:
                    self.per_env_buf[i].append(ep)
                if self.non_rolling_buf is not None:
                    self.non_rolling_buf.append(ep)
                self.epcount += 1
                self.eprets[i] = 0
                self.eplens[i] = 0