firezdog

from collections import defaultdict
from concurrent.futures import ThreadPoolExecutor as Executor
from time import sleep


def async_map(executor: Executor, mapper, data):
    return [executor.submit(mapper, datum) for datum in data]


def report_progress(futures, tag, callback):