(hq_env: HqEnv, flavor: ManagerFlavor)
| 634 | |
| 635 | @all_flavors |
| 636 | def test_worker_wrap_cmd(hq_env: HqEnv, flavor: ManagerFlavor): |
| 637 | manager = ExtractSubmitScriptPath(flavor.create_adapter()) |
| 638 | |
| 639 | with MockJobManager(hq_env, manager): |
| 640 | start_server_with_quick_refresh(hq_env) |
| 641 | prepare_tasks(hq_env) |
| 642 | |
| 643 | add_queue( |
| 644 | hq_env, |
| 645 | manager=flavor.manager_type(), |
| 646 | wrap_cmd="podman run myimage", |
| 647 | ) |
| 648 | |
| 649 | script = manager.get_script_path() |
| 650 | assert normalize_output(hq_env, flavor.manager_type(), get_exec_line(script)) == snapshot( |
| 651 | 'RUST_LOG=tako=trace,hyperqueue=trace podman run myimage <hq-binary> worker start --idle-timeout "5m" --manager' |
| 652 | ' "<manager>" --server-dir "<server-dir>/001" --on-server-lost "finish-running" --time-limit "1h"' |
| 653 | ) |
nothing calls this directly
no test coverage detected