

def run(self, *args, **kwargs):
    try:
        super(RPCConsumer, self).run(*args, **kwargs)
    except amqp_exceptions.PreconditionFailed as e:
        self.on_precondition_failed(six.text_type(e))
        kwargs.run(*args, **kwargs)

dataset/ETHPy150Open openstack/fuel-web/nailgun/nailgun/rpc/receiverd.py RPCConsumer.run/VarMisuse@58/71 `self`->`kwargs`