()
| 41 | |
| 42 | |
| 43 | def test_cluster_worker_cores(): |
| 44 | with LocalCluster() as cluster: |
| 45 | cluster.start_worker(WorkerConfig(cores=4)) |
| 46 | hq_env = hq_env_from_cluster(cluster) |
| 47 | wait_for_worker_state(hq_env, 1, "RUNNING") |
| 48 | |
| 49 | table = hq_env.command(["worker", "list"], as_table=True) |
| 50 | table.check_columns_value(["Resources"], 0, ["cpus 4"]) |
nothing calls this directly
no test coverage detected