First delivery: Reject(requeue=True). Second delivery: succeed normally.
(self)
| 537 | |
| 538 | @shared_task(bind=True, acks_late=True) |
| 539 | def reject_then_succeed(self): |
| 540 | """First delivery: Reject(requeue=True). Second delivery: succeed normally.""" |
| 541 | if not self.request.delivery_info.get('redelivered'): |
| 542 | raise Reject(requeue=True) |
| 543 | return 'second-pass' |
| 544 | |
| 545 | |
| 546 | @shared_task(soft_time_limit=2, time_limit=1) |