b6dfa65bcc12dd78637838d0943c4c6e1221258b,parlai/mturk/core/socket_manager.py,SocketManager,open_channel,#SocketManager#Any#Any#,519

Before Change

                        time.sleep(shared_utils.THREAD_SHORT_SLEEP)

        // Setup and run the channel sending thread
        self.threads[connection_id] = threading.Thread(
            target=channel_thread,
            name="Socket-Queue-{}".format(connection_id)
        )
        self.threads[connection_id].daemon = True
        self.threads[connection_id].start()

    def close_channel(self, connection_id):
        Closes a channel by connection_id
        shared_utils.print_and_log(

After Change

        self.last_sent_heartbeat_time[connection_id] = 0
        self.pongs_without_heartbeat[connection_id] = 0
        self.last_received_heartbeat[connection_id] = None
        self.worker_assign_ids[connection_id] = (worker_id, assignment_id)

    def close_channel(self, connection_id):
        Closes a channel by connection_id
        shared_utils.print_and_log(

Instances