code: def create_sshd_worker_cmd(
      allocation_id: str, num_slot_ids: int, debug: bool = False
  ) -> Tuple[List[str], List[str]]:
      # Wrap it in a pid_server to ensure that we can't hang if a worker fails.
      # TODO: After the upstream horovod bugfix (github.com/horovod/horovod/pull/3060) is in a
      # widely-used release of horovod, we should remove this pid_server layer, which just adds
      # unnecessary complexity.
      pid_server_cmd = [
          "python3",
          "-m",
          "determined.exec.pid_server",
          "--on-fail",
          "SIGTERM",
          "--on-exit",
          "SIGTERM",
          "--signal-children",
          f"/tmp/pid_server-{allocation_id}",
          str(num_slot_ids),
          "--",
      ]
  
      run_sshd_command = [
          "/usr/sbin/sshd",
          "-p",
          str(DTRAIN_SSH_PORT),
          "-f",
          "/run/determined/ssh/sshd_config",
          "-D",
      ]
      if debug:
          run_sshd_command.append("-e")
      return pid_server_cmd, run_sshd_command
  
file_path: determined/harness/determined/launch/horovod.py
imports: import argparse
  import logging
  import os
  import subprocess
  import sys
  import time
  from typing import List, Tuple
  import determined
  from determined import horovod, util
  from determined.common import api
  from determined.common.api import certs
  from determined.constants import DTRAIN_SSH_PORT
label_desc: Use image node_id 1 for calling a global function with example usage: create_sshd_worker_cmd(allocation_id, num_slot_ids, debug) and returns: pid_server_cmd,  run_sshd_command