

@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(reminder_id):
            _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/VarMisuse@37/59 `domain`->`reminder_id`