32e10b42eeac0dc66beb57221d9fee265b6976b1,parlai/core/teachers.py,ChunkTeacher,_drain,#ChunkTeacher#Any#,2381

Before Change

    def _drain(self, q):
        with q.mutex:
            q.queue.clear()

    def reset(self):
        super().reset()
        if self.is_root_teacher:

After Change

        return msg

    def _drain(self, q):
        while not q.empty():
            try:
                q.get()
            except queue.Empty:
                return

    def reset(self):
        super().reset()
        if self.is_root_teacher:

Instances