def handle_message(self, body, message):
        try:
            args = body['args']
            kwargs = body['kwargs']
        except __HOLE__:
            raise MalformedRequest('Message missing `args` or `kwargs`')

        self.check_signature(args, kwargs)

        worker_ctx_cls = self.container.worker_ctx_cls
        context_data = self.unpack_message_headers(worker_ctx_cls, message)

        handle_result = partial(self.handle_result, message)
        try:
            self.container.spawn_worker(self, args, kwargs,
                                        context_data=context_data,
                                        handle_result=handle_result)
        except ContainerBeingKilled:
            self.rpc_consumer.requeue_message(message)
dataset/ETHPy150Open onefinestay/nameko/nameko/rpc.py/Rpc.handle_message