from tqdm.contrib.concurrent import process_map # email provider extraction function def provider_extraction(email): return email.split("@")[1].split(".")[0] # applying the function with customization df["email_provider"] = process_map( provider_extraction, df["email"], max_workers=8, chunksize=64, desc="Extracting Email provider", colour='green' ) df["email_provider"].head().to_frame()