def import_to_datastore(schools_description_filepath, schools_coordinates_filepath, batch_size):
    try:
        assert batch_size > 0
        started = datetime.now()
        schools = get_schools_with_description(
            schools_description_filepath, schools_coordinates_filepath
        )
        truncate_schools_with_description()
        new_items = 0
        logging.info("inserting " + str(len(schools)) + " new schools")
        for schools_chunk in chunks(schools, batch_size):
            db.session.bulk_insert_mappings(SchoolWithDescription2020, schools_chunk)
            db.session.commit()
        new_items += len(schools)
        logging.info(f"\t{new_items} items in {time_delta(started)}")
        return new_items
    except Exception as exception:
        error = f"Schools import succeeded partially with {new_items} schools. Got exception : {exception}"
        raise Exception(error)