

def reject(self, requeue=True):
    self._error_if_already_terminated()
    self._channel.basic.reject(self.tag, requeue=requeue)

dataset/ETHPy150Open seatgeek/cronq/cronq/runner.py AMQPProxy.reject/original