oarepo_oaipmh_harvester.oai_harvester.tasks

@shared_task
def index_oai_harvesters() -> None:
    """Reindex OAI harvesters."""
    oai_harvesters = (
        db.session.query(OAIHarvester.id)
        .filter(OAIHarvester.last_update_time > dt.datetime.now(dt.UTC) - dt.timedelta(days=1))
        .yield_per(1000)
    )

    current_oai_harvester_service.indexer.bulk_index([u.id for u in oai_harvesters])