tfx/orchestration/launcher/kubernetes_component_launcher.py [195:210]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    spec.update({'restartPolicy': 'Never'})
    containers = spec.setdefault('containers', [])  # type: List[Dict[str, Any]]
    container = None  # type: Optional[Dict[str, Any]]
    for c in containers:
      if c['name'] == kube_utils.ARGO_MAIN_CONTAINER_NAME:
        container = c
        break
    if not container:
      container = {'name': kube_utils.ARGO_MAIN_CONTAINER_NAME}
      containers.append(container)
    container.update({
        'image': container_spec.image,
        'command': container_spec.command,
        'args': container_spec.args,
    })
    return pod_manifest
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tfx/orchestration/portable/kubernetes_executor_operator.py [191:206]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    spec.update({'restartPolicy': 'Never'})
    containers = spec.setdefault('containers', [])  # type: List[Dict[str, Any]]
    container = None  # type: Optional[Dict[str, Any]]
    for c in containers:
      if c['name'] == kube_utils.ARGO_MAIN_CONTAINER_NAME:
        container = c
        break
    if not container:
      container = {'name': kube_utils.ARGO_MAIN_CONTAINER_NAME}
      containers.append(container)
    container.update({
        'image': container_spec.image,
        'command': container_spec.command,
        'args': container_spec.args,
    })
    return pod_manifest
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -