def verify_ids()

in src/data_load/load.py [0:0]

• 19 lines of code
• 6 McCabe index (conditional complexity)

def verify_ids(record_ids):
    success = []
    failed = []
    search_query = create_search_query(record_ids)
    logger.debug(f"search query {search_query}")

    headers = get_headers(config)
    response = requests.post(SEARCH_URL, json.dumps(search_query),
                             headers=headers)

    if response.status_code in DATA_LOAD_OK_RESPONSE_CODES:
        search_response = response.json()
        logger.debug(f"search response {search_response}")
        ingested_records = search_response.get("results")

        for ingested_record in ingested_records:
            success.append(ingested_record.get("id"))

    failed = [x for x in record_ids if x not in success]
    if len(failed) > 0:
        logger.error(
            f"Failed to ingest Records {len(failed)} with Ids: {failed}")

    return success, failed