oarepo_oaipmh_harvester.oai_record.tasks

@shared_task
def index_oai_records() -> None:
    """Reindex harvested records updated in the last day."""
    oai_records = (
        db.session.query(OAIHarvestedRecord.id)
        .filter(OAIHarvestedRecord.last_update_time > dt.datetime.now(dt.UTC) - dt.timedelta(days=1))
        .yield_per(1000)
    )

    current_oai_record_service.indexer.bulk_index([u.id for u in oai_records])