def METHOD_NAME(
    app,
    create_records,
    celery_app_with_context,
    celery_session_worker
):
    records = create_records(n=1)
    uuid = str(records[0].id)
    task = batch_reindex.apply_async(kwargs={'uuids': [uuid]})
    result = task.get(timeout=10)
    expected = {'failures': [], 'success': 1}
    assert result == expected
    control_number = records[0].json['control_number']
    assert get_es_record('lit', control_number)