def METHOD_NAME(
    mock_api_post: mock.MagicMock,
    mock_cluster_info: mock.MagicMock,
    mock_popen: mock.MagicMock,
) -> None:
    info = test_util.make_mock_cluster_info(["0.0.0.0", "0.0.0.1"], 1, num_slots=1)
    mock_cluster_info.return_value = info
    hvd_args = ["ds1", "ds2"]
    script = ["s1", "s2"]
    pid_server_cmd, run_sshd_cmd = launch.horovod.create_sshd_worker_cmd(
        info.allocation_id,
        len(info.slot_ids),
    )
    launch_cmd = pid_server_cmd + run_sshd_cmd
    mock_proc = mock.MagicMock()
    mock_proc.wait.return_value = 99
    mock_popen.return_value = mock_proc
    with test_util.set_resources_id_env_var():
        assert launch.horovod.main(hvd_args, script, True) == 99
    mock_cluster_info.assert_called_once()
    assert os.environ["DET_CHIEF_IP"] == info.container_addrs[0]
    assert os.environ["USE_HOROVOD"] == "1"
    mock_popen.assert_has_calls([mock.call(launch_cmd)])
    mock_api_post.assert_has_calls(
        [
            mock.call(
                info.master_url,
                path=f"/api/v1/allocations/{info.allocation_id}/resources/resourcesId/daemon",
                cert=certs.cli_cert,
            )
        ]
    )
    mock_proc.wait.assert_called_once()