def handle(self, msg):
        identity = msg[0]
        args = tuple(msg[1:])

        if self.futures in args:
            future = self.futures[args]
        else:
            future = self.pool.submit(self.get_response, *args)
            self.futures[args] = future

        self.loop.add_future(
            future, functools.partial(self.reply, identity)
        )
dataset/ETHPy150Open onitu/onitu/onitu/brocker/brocker.py/Brocker.handle/swapped operands of `in`