(worker_threads=128)
| 111 | |
| 112 | |
| 113 | def single_node_dask_cluster(worker_threads=128) -> DaskClusterInfo: |
| 114 | return DaskClusterInfo( |
| 115 | cluster_info=ClusterInfo(monitor_nodes=True, node_list=Local()), |
| 116 | environment_params=dict(worker_threads=worker_threads), |
| 117 | workers=[DaskWorkerConfig(processes=1, threads_per_process=worker_threads)], |
| 118 | ) |
| 119 | |
| 120 | |
| 121 | def get_hq_binary(**kwargs) -> Path: |
nothing calls this directly
no test coverage detected