code: def get_remote_command(
      local_command, host, port=None, identity_file=None, timeout_s=None
  ):
      return (
          f"{env_util.KUBEFLOW_MPI_EXEC} {host} {local_command}"
          if env_util.is_kubeflow_mpi()
          else get_ssh_command(
              local_command, host, port, identity_file, timeout_s
          )
      )
  
label_desc: Use image node_id 2 for calling a global function with example usage: get_remote_command(local_command, host, port, identity_file, timeout_s) and returns: unknown