Async: push_not_registered_user_data_task.apply_async(args=[data], countdown=100)

def push_not_registered_user_data_task(data):
    """
    Async: push_not_registered_user_data_task.apply_async(args=[data], countdown=100)
    """
    lock_id = "%s-push-not-registered-user-data-task-%s" % (settings.ENV_PREFIX, data["email"])
    acquire_lock = lambda: cache.add(lock_id, "true", LOCK_EXPIRE)  # noqa: E731
    release_lock = lambda: cache.delete(lock_id)  # noqa: E731

    if acquire_lock():
        try:
            upload_not_registered_user_data(data)
        except (KeyError, NotImplementedError, MultipleMatchingUsersError):
            release_lock()
            raise
        release_lock()