tfx/orchestration/kubeflow/v2/step_builder.py [509:529]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    result.image = self._tfx_image
    if self._image_cmds:
      for cmd in self._image_cmds:
        result.command.append(cmd)
    executor_path = name_utils.get_full_name(
        self._node.executor_spec.executor_class)
    # Resolve container arguments.
    result.args.append('--executor_class_path')
    result.args.append(executor_path)
    result.args.append('--json_serialized_invocation_args')
    # from kfp dsl: PIPELINE_TASK_EXECUTOR_INPUT_PLACEHOLDER
    result.args.append('{{$}}')

    if self._use_pipeline_spec_2_1:
      result.args.append('--json_serialized_inputs_spec_args')
      result.args.append(
          json_format.MessageToJson(
              self._component_defs[self._name].input_definitions, sort_keys=True
          )
      )
    result.args.extend(self._beam_pipeline_args)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tfx/orchestration/kubeflow/v2/step_builder.py [576:594]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    result.image = self._tfx_image
    if self._image_cmds:
      for cmd in self._image_cmds:
        result.command.append(cmd)
    executor_path = name_utils.get_full_name(
        self._node.executor_spec.executor_class)
    # Resolve container arguments.
    result.args.append('--executor_class_path')
    result.args.append(executor_path)
    result.args.append('--json_serialized_invocation_args')
    result.args.append('{{$}}')
    if self._use_pipeline_spec_2_1:
      result.args.append('--json_serialized_inputs_spec_args')
      result.args.append(
          json_format.MessageToJson(
              self._component_defs[self._name].input_definitions, sort_keys=True
          )
      )
    result.args.extend(self._beam_pipeline_args)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -