Celery Task with Exponential Backoff

from celery import shared_task
from celery.exceptions import MaxRetriesExceededError

@shared_task(bind=True, max_retries=5, acks_late=True)
def process_event(self, event_id: str):
    try:
        do_work(event_id)
    except Exception as exc:
        delay = 2 ** self.request.retries * 15
        try:
            raise self.retry(exc=exc, countdown=delay)
        except MaxRetriesExceededError:
            send_to_dead_letter(event_id, str(exc))