def METHOD_NAME(pool, func, inputs, method_kwargs=None, task_name=""):
    """Run function in parallel async"""
    results = []
    for arguments in progress_bar(inputs, desc=task_name):
        result = pool.apply_async(func, arguments, **method_kwargs)
        results.append(result)
    # wait async run is done
    [result.wait() for result in results]
    return results