def METHOD_NAME(collection_path):
    print_message("#> Loading collection...")
    collection = []
    with open(collection_path) as f:
        csv_reader = csv.DictReader(f, fieldnames=["pid", "passage", "title"], delimiter="\t")
        for line_idx, row in enumerate(csv_reader):
            if line_idx % (1000*1000) == 0:
                print(f'{line_idx // 1000 // 1000}M', end=' ', flush=True)
            pid = row["pid"]
            assert pid == 'id' or int(pid) == line_idx
            passage = row["passage"]
            if row["title"] is not None:
                passage = row["title"] + ' | ' + passage
            collection.append(passage)
    print()
    return collection