from celery.task import task


@task
def subscribe(email, newsletter_list, lang=None, user=None):
    from courriers.backends import get_backend

    backend = get_backend()()

    try:
        backend.register(email=email,
                         newsletter_list=newsletter_list,
                         lang=lang,
                         user=user)
    except Exception as e:
        raise subscribe.retry(args=[email, newsletter_list, lang, user], exc=e, countdown=5)


@task
def unsubscribe(email, newsletter_list=None, lang=None, user=None):
    from courriers.backends import get_backend

    backend = get_backend()()

    try:
        backend.unregister(email=email,
                           newsletter_list=newsletter_list,
                           lang=lang,
                           user=user)
    except Exception as e:
        raise unsubscribe.retry(args=[email, newsletter_list, lang, user], exc=e, countdown=5)

from celery.task import task


@task
def subscribe(email, newsletter_list, lang=None, user=None):
    from courriers.backends import get_backend

    backend = get_backend()()

    try:
        backend.register(email=email,
                         newsletter_list=newsletter_list,
                         lang=lang,
                         user=user)
    except Exception as e:
        raise subscribe.retry(args=[email, newsletter_list, lang, user], exc=e, countdown=30)


@task
def unsubscribe(email, newsletter_list=None, lang=None, user=None):
    from courriers.backends import get_backend

    backend = get_backend()()

    try:
        backend.unregister(email=email,
                           newsletter_list=newsletter_list,
                           lang=lang,
                           user=user)
    except Exception as e:
        raise unsubscribe.retry(args=[email, newsletter_list, lang, user], exc=e, countdown=30)

Fix the delay for subscription and unsubscription retry
Fix the delay for subscription and unsubscription retry
