def METHOD_NAME():
    """Retries failed OpenAIRE indexing/deletion operations."""
    cache = current_cache.cache
    redis_client = cache._read_clients
    failed_recids = redis_client.scan_iter(
        match=(cache.key_prefix + 'openaire_direct_index:*'),
        count=1000,
    )
    for key in failed_recids:
        recid_value = key.split('openaire_direct_index:')[1]
        recid = PersistentIdentifier.query.filter_by(
            pid_type='recid', pid_value=recid_value).one_or_none()
        record = ZenodoRecord.get_record(recid.object_uuid, with_deleted=True)
        if 'resource_type' in record:
            openaire_direct_index.delay(str(record.id), retry=False)
        else:
            openaire_delete.delay(str(record.id))