_profiled_batch_func.py

def _profiled_batch_func(process_func: Callable[..., None],
                         list_kwargs: List[KwargsType],
                         shared_kwargs: KwargsType) -> List[Tuple[float, float]]:
    """Process and profile a batch"""
    profiling_events: List[Tuple[float, float]] = []

    for kwargs in list_kwargs:
        start_time = time.perf_counter()
        process_func(**kwargs, **shared_kwargs)
        end_time = time.perf_counter()
        profiling_events.append((start_time, end_time))

    return profiling_events