Function test_cluster_add_worker

tests/pyapi/test_cluster.py:31–40

()

def test_cluster_add_worker():
    with LocalCluster() as cluster:
        cluster.start_worker()
        client = cluster.client()
        job = Job()
        job.program(["echo", "hello"], stdout="out.txt")
        job_id = client.submit(job)
        client.wait_for_jobs([job_id])

        check_file_contents("out.txt", "hello\n")


def test_cluster_worker_cores():