@task(queue=CELERY_REMINDERS_QUEUE, ignore_result=True, acks_late=True)
def fire_reminder(reminder_id, domain):
    try:
        if reminder_rate_limiter.can_perform_action(domain):
            _fire_reminder(reminder_id)
        else:
            fire_reminder.apply_async(args=[reminder_id, domain], countdown=60)
    except Exception:
        notify_exception(None,
            message="Error firing reminder %s" % reminder_id)
dataset/ETHPy150Open dimagi/commcare-hq/corehq/apps/reminders/tasks.py/fire_reminder/original