

@task(queue=settings.CELERY_REMINDER_RULE_QUEUE, ignore_result=True, acks_late=True)
def process_reminder_rule(handler, schedule_changed, prev_definition, send_immediately):
    try:
        handler.process_rule(schedule_changed, prev_definition, send_immediately)
    except Exception:
        notify_exception(None, message=('Error processing reminder rule for handler %s' % handler._id))
    handler.save(unlock=True)

dataset/ETHPy150Open dimagi/commcare-hq/corehq/apps/reminders/tasks.py process_reminder_rule/original