code: def get_cmd(self, environment, active_resources):
      environment["PDSH_RCMD_TYPE"] = "ssh"
  
      active_workers = ",".join(active_resources.keys())
      logger.info(
          "Running on the following workers: %s" % active_workers
      )
  
      # PDSH flags for max node fan out and specific hosts to launch on
      # See https://linux.die.net/man/1/pdsh for flag details
      pdsh_cmd_args = [
          "pdsh",
          "-S",
          "-f",
          str(PDSH_MAX_FAN_OUT),
          "-w",
          active_workers,
      ]
  
      exports = ""
      for key, val in self.exports.items():
          exports += "export {}={}; ".format(key, val)
  
      # https://linux.die.net/man/1/pdsh
      # %n will be replaced by pdsh command
      deepspeed_launch = [
          exports,
          f"cd {os.path.abspath('.')};",
          sys.executable,
          "-u",
          "-m",
          "deepspeed.launcher.launch",
          f"--world_info={self.world_info_base64}",
          "--node_rank=%n",
          f"--master_addr={self.args.master_addr}",
          f"--master_port={self.args.master_port}",
      ]
      if self.args.no_python:
          deepspeed_launch.append("--no_python")
      if self.args.module:
          deepspeed_launch.append("--module")
      if self.args.no_local_rank:
          deepspeed_launch.append("--no_local_rank")
      if self.args.save_pid:
          deepspeed_launch += ["--save_pid", f"{os.getpid()}"]
      if self.args.elastic_training:
          deepspeed_launch.append("--enable_elastic_training")
          deepspeed_launch.append(
              f"--max_elastic_nodes={self.args.max_elastic_nodes}"
          )
          deepspeed_launch.append(
              f"--min_elastic_nodes={self.args.min_elastic_nodes}"
          )
  
      cmd_to_search = [i + "\\" for i in deepspeed_launch[2:6]]
  
      kill_command = pdsh_cmd_args + [
          "pkill -f ",
          " ".join(cmd_to_search)[:-2],
      ]
      return (
          pdsh_cmd_args
          + deepspeed_launch
          + [self.user_script]
          + self.user_arguments,
          kill_command,
      )
  
imports: import os
  import sys
  import shutil
  import subprocess
  import warnings
  from shlex import split
  from abc import ABC, abstractmethod
  from ..utils import logger
  from .constants import PDSH_MAX_FAN_OUT, MVAPICH_TMP_HOSTFILE
label_desc: Use image node_id 5 for calling the PDSHRunner obj's underlying member method code with example usage: obj.get_cmd(environment, active_resources) and returns: unknown,  kill_command