(self, env: DaskEnvironment)
| 44 | |
| 45 | class SleepDask(Sleep): |
| 46 | def execute(self, env: DaskEnvironment) -> WorkloadExecutionResult: |
| 47 | from distributed import Client |
| 48 | |
| 49 | def run(client: Client): |
| 50 | tasks = client.map(sleep, [self.sleep_duration] * self.task_count, pure=False) |
| 51 | client.gather(tasks) |
| 52 | |
| 53 | return measure_dask_tasks(env, run) |
| 54 | |
| 55 | |
| 56 | class SleepDaskSpawn(Sleep): |
nothing calls this directly
no test coverage detected