Function store_success_then_reject

t/integration/tasks.py:526–535

First delivery: store SUCCESS manually, then Reject to trigger redelivery. Second delivery: dedup finds SUCCESS, dispatches chain.

(self)

@shared_task(bind=True, acks_late=True)
def store_success_then_reject(self):
    """First delivery: store SUCCESS manually, then Reject to trigger redelivery.
    Second delivery: dedup finds SUCCESS, dispatches chain."""
    from celery.backends.base import states
    if not self.request.delivery_info.get('redelivered'):
        self.backend.store_result(self.request.id, 'first-pass', states.SUCCESS)
        raise Reject(requeue=True)
    # When dedup is enabled the fast-path intercepts before reaching here,
    # so 'dedup-pass' is only returned when dedup is disabled.
    return 'dedup-pass'


@shared_task(bind=True, acks_late=True)