Method execute

benchmarks/src/workloads/empty.py:22–29

(self, env: DaskEnvironment)

        return {"task_count": self.task_count}

    def execute(self, env: DaskEnvironment) -> WorkloadExecutionResult:
        from distributed import Client

        def run(client: Client):
            tasks = [client.submit(empty, pure=False) for _ in range(self.task_count)]
            client.gather(tasks)

        return measure_dask_tasks(env, run)