tfx/orchestration/portable/launcher.py [279:294]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                          self._pipeline_node.node_info.id, e)
        execution = self._register_or_reuse_execution(
            metadata_handle=m,
            contexts=contexts,
            exec_properties=exec_properties,
        )
        if not execution_lib.is_execution_successful(execution):
          self._publish_failed_execution(
              execution_id=execution.id,
              contexts=contexts,
              executor_output=self._build_error_output(code=e.grpc_code_value))
        return _ExecutionPreparationResult(
            execution_info=self._build_execution_info(
                execution_id=execution.id),
            contexts=contexts,
            is_execution_needed=False)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tfx/orchestration/portable/launcher.py [353:368]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                          self._pipeline_node.node_info.id, e)
        execution = self._register_or_reuse_execution(
            metadata_handle=m,
            contexts=contexts,
            exec_properties=exec_properties,
        )
        if not execution_lib.is_execution_successful(execution):
          self._publish_failed_execution(
              execution_id=execution.id,
              contexts=contexts,
              executor_output=self._build_error_output(code=e.grpc_code_value))
        return _ExecutionPreparationResult(
            execution_info=self._build_execution_info(
                execution_id=execution.id),
            contexts=contexts,
            is_execution_needed=False)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -