b985e691310c9a2d88b58be2dfecaf9197ea6f5e,parlai/mturk/core/mturk_manager.py,MTurkManager,_move_workers_to_waiting,#MTurkManager#Any#,183

Before Change

            worker_id = worker.worker_id
            assignment_id = worker.assignment_id
            assignment = \
                self.worker_state[worker_id].assignments[assignment_id]
            if assignment.is_final():
                //This worker must"ve disconnected or expired, remove them
                if assignment_id in self.mturk_agents[worker_id]:

After Change

            assignment_id = worker.assignment_id
            if worker.state.is_final():
                worker.reduce_state()
                self.socket_manager.close_channel(worker.get_connection_id())
                continue

            conversation_id = "w_{}".format(uuid.uuid4())

Instances