67fa4171fffad014ef7f072ef56426e52080fcb5,src/fetch_suspicious_places.py,,search_suspicious_around_companies,#Any#,141

Before Change

    
    :param companies: pandas dataframe.
    
    rows = companies.to_dict("records")
    total = len(rows)
    count = 0
    with Pool(processes=4) as pool:
        for company in pool.imap(search_suspicious_around_company, rows):
            count += 1
            print_status(total, count)
            if company:
                write_csv(company)


def search_suspicious_around_company(company):
    
    :param company: (dict)
    :return: suspect

After Change

            company = dict(company._asdict())  // _asdict() gives OrderedDict
            q.put(csv_line(search_suspicious_around_company(company)))

    write_queue = Queue()
    place_search = Process(target=make_queue, args=(write_queue, companies))
    place_search.start()

    with lzma.open(OUTPUT, "at") as output:
        while place_search.is_alive() or not write_queue.empty():

Instances