code: def _run_internal(self,
                      context,
                      pipeline_key,
                      root_pipeline_key,
                      caller_output):
      
      self._set_values_internal(
          context, pipeline_key, root_pipeline_key, caller_output,
          _PipelineRecord.RUN)
      logging.debug('Running %s(*%s, **%s)#%s',
                    self._class_path, _short_repr(self.args),
                    _short_repr(self.kwargs), self._pipeline_key.name())
      return self.run(*self.args, **self.kwargs)
docs: Used by the Pipeline evaluator to execute this Pipeline.