code: def _finalized_internal(self,
                            context,
                            pipeline_key,
                            root_pipeline_key,
                            caller_output,
                            aborted):
      
      result_status = _PipelineRecord.RUN
      if aborted:
        result_status = _PipelineRecord.ABORTED
  
      self._set_values_internal(
          context, pipeline_key, root_pipeline_key, caller_output, result_status)
      logging.debug('Finalizing %s(*%r, **%r)#%s',
                    self._class_path, _short_repr(self.args),
                    _short_repr(self.kwargs), self._pipeline_key.name())
      try:
        self.finalized()
      except NotImplementedError:
        pass
docs: Used by the Pipeline evaluator to finalize this Pipeline.