Function measure_dask_tasks

benchmarks/src/workloads/utils.py:108–117

(env: Environment, submit_fn: Callable[["distributed.Client"], None])

def measure_dask_tasks(env: Environment, submit_fn: Callable[["distributed.Client"], None]) -> WorkloadExecutionResult:
    from ..environment.dask import DaskEnvironment

    assert isinstance(env, DaskEnvironment)
    logging.debug("[Dask] Submitting")

    timer = Timings()
    with timer.time():
        submit_fn(env.get_client())
    return create_result(timer.duration())


def create_result(duration: float) -> WorkloadExecutionResult: