(hq_env: HqEnv)
| 378 | |
| 379 | |
| 380 | def test_deploy_ssh_multiple_workers(hq_env: HqEnv): |
| 381 | hq_env.start_server() |
| 382 | with hq_env.mock.mock_program_with_code( |
| 383 | "ssh", |
| 384 | """ |
| 385 | import os |
| 386 | |
| 387 | os.makedirs("workers", exist_ok=True) |
| 388 | with open(f"workers/{os.getpid()}", "w") as f: |
| 389 | f.write(str(os.getpid())) |
| 390 | """, |
| 391 | ): |
| 392 | nodefile = prepare_localhost_nodefile(count=3) |
| 393 | hq_env.command(["worker", "deploy-ssh", nodefile]) |
| 394 | assert len(os.listdir("workers")) == 3 |
| 395 | |
| 396 | |
| 397 | def test_deploy_ssh_show_output(hq_env: HqEnv): |
nothing calls this directly
no test coverage detected