file the worker logs to. See Logging. loglevel: The current log level used. delivery_info: Additional message delivery information. This is a mapping containing the exchange and routing key used to exception will be raised instead. Not supported by amqplib. Task.immediate Request immediate delivery. If the task cannot be routed to a task worker immediately, an exception will be raised. This is This sets the delivery to be mandatory. An exception will be raised if there are no running workers able to take on the task. Not supported by amqplib. immediate Request immediate delivery. Will raise

log level used. hostname Hostname of the worker instance executing the task. delivery_info Additional message delivery information. This is a mapping containing the exchange and rout- ing key used to exception will be raised instead. Not supported by amqplib. Task.immediate Request immediate delivery. If the task cannot be routed to a task worker immediately, an exception will be raised. This is This sets the delivery to be mandatory. An exception will be raised if there are no running workers able to take on the task. Not supported by amqplib. • immediate Request immediate delivery. Will raise

The file the worker logs to. See Logging. loglevel The current log level used. delivery_info Additional message delivery information. This is a mapping containing the exchange and rout- ing key used to exception will be raised instead. Not supported by amqplib. Task.immediate Request immediate delivery. If the task cannot be routed to a task worker immediately, an exception will be raised. This is This sets the delivery to be mandatory. An exception will be raised if there are no running workers able to take on the task. Not supported by amqplib. • immediate Request immediate delivery. Will raise

log level used. hostname: Hostname of the worker instance executing the task. delivery_info: Additional message delivery information. This is a mapping containing the exchange and routing key used to exception will be raised instead. Not supported by amqplib. Task.immediate Request immediate delivery. If the task cannot be routed to a task worker immediately, an exception will be raised. This is This sets the delivery to be mandatory. An exception will be raised if there are no running workers able to take on the task. Not supported by amqplib. immediate Request immediate delivery. Will raise

log level used. hostname Hostname of the worker instance executing the task. delivery_info Additional message delivery information. This is a mapping containing the exchange and rout- ing key used to exception will be raised instead. Not supported by amqplib. Task.immediate Request immediate delivery. If the task cannot be routed to a task worker immediately, an exception will be raised. This is This sets the delivery to be mandatory. An exception will be raised if there are no running workers able to take on the task. Not supported by amqplib. • immediate Request immediate delivery. Will raise

log level used. hostname: Hostname of the worker instance executing the task. delivery_info: Additional message delivery information. This is a mapping containing the exchange and routing key used to exception will be raised instead. Not supported by amqplib. Task.immediate Request immediate delivery. If the task cannot be routed to a task worker immediately, an exception will be raised. This is This sets the delivery to be mandatory. An exception will be raised if there are no running workers able to take on the task. Not supported by amqplib. immediate Request immediate delivery. Will raise

to the workers log file. See Logging. loglevel: The current log level used. delivery_info: Additional message delivery information. This is a mapping containing the exchange and routing key used to to the task. In addition, it also uses the task_id keyword argument to use the same task id, and delivery_info to route the retried task to the same destination. Using a custom retry delay When a task exception will be raised instead. Not supported by amqplib. Task.immediate Request immediate delivery. If the task cannot be routed to a task worker immediately, an exception will be raised. This is

enable_utc setting). hostname: Node name of the worker instance executing the task. delivery_info: Additional message delivery information. This is a mapping containing the exchange and routing key used to import Reject @app.task(bind=True, acks_late=True) def requeues(self): if not self.request.delivery_info['redelivered']: raise Reject('no reason', requeue=True) print('received two times') Pop a message off the queue: 5> basic.get testqueue {'body': 'This is a message!', 'delivery_info': {'delivery_tag': 1, 'exchange': u'testexchange', 'message_count':

enable_utc setting). hostname: Node name of the worker instance executing the task. delivery_info: Additional message delivery information. This is a mapping containing the exchange and routing key used to import Reject @app.task(bind=True, acks_late=True) def requeues(self): if not self.request.delivery_info['redelivered']: raise Reject('no reason', requeue=True) print('received two times') Pop a message off the queue: 5> basic.get testqueue {'body': 'This is a message!', 'delivery_info': {'delivery_tag': 1, 'exchange': u'testexchange', 'message_count':

access to the workers log file. See Logging. loglevel The current log level used. delivery_info Additional message delivery information. This is a mapping containing the exchange and rout- ing key used to to the task. In addition, it also uses the task_id keyword argument to use the same task id, and delivery_info to route the retried task to the same destination. Using a custom retry delay When a task exception will be raised instead. Not supported by amqplib. Task.immediate Request immediate delivery. If the task cannot be routed to a task worker immediately, an exception will be raised. This is