code: def test_sshd_worker(
      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()
  
file_path: determined/harness/tests/launch/test_horovod.py
imports: import os
  import time
  from unittest import mock
  import pytest
  import determined.launch.horovod
  from determined import constants, horovod, launch
  from determined.common.api import certs
  from tests.launch import test_util
label_desc: Use image node_id 3 for calling a global function with example usage: test_sshd_worker(mock_api_post, mock_cluster_info, mock_popen) without return types