python_modules/dagster/dagster/core/execution.py
def transformed_value(self, output_name=DEFAULT_OUTPUT):
        '''Returns transformed value either for DEFAULT_OUTPUT or for the output
        given as output_name. Returns None if execution result isn't a success.

        Reconstructs the pipeline context to materialize value.
        '''
        check.str_param(output_name, 'output_name')

        if not self.solid.definition.has_output(output_name):
            raise DagsterInvariantViolationError(
                '{output_name} not defined in solid {solid}'.format(
                    output_name=output_name, solid=self.solid.name
                )
            )

        if self.success:
            for result in self.transforms:
                if (
                    result.is_successful_output
                    and result.step_output_data.output_name == output_name
                ):
                    with self.reconstruct_context() as context:
                        value = self._get_value(context, result.step_output_data)
                    return value

            raise DagsterInvariantViolationError(
                (
                    'Did not find result {output_name} in solid {self.solid.name} '
                    'execution result'
                ).format(output_name=output_name, self=self)
            )
        else:
            return None
def transformed_value(self, output_name=DEFAULT_OUTPUT):
        '''Returns transformed value either for DEFAULT_OUTPUT or for the output
        given as output_name. Returns None if execution result isn't a success.

        Reconstructs the pipeline context to materialize value.
        '''
        check.str_param(output_name, 'output_name')

        if not self.solid.definition.has_output(output_name):
            raise DagsterInvariantViolationError(
                '{output_name} not defined in solid {solid}'.format(
                    output_name=output_name, solid=self.solid.name
                )
            )

        if self.success:
            for result in self.transforms:
                if (
                    result.is_successful_output
                    and result.step_output_data.output_name == output_name
                ):
                    with self.reconstruct_context() as context:
                        value = self._get_value(context, result.step_output_data)
                    return value

            raise DagsterInvariantViolationError(
                (
                    'Did not find result {output_name} in solid {self.solid.name} '
                    'execution result'
                ).format(output_name=output_name, self=self)
            )
        else:
            return None
def transformed_value ( self , output_name = DEFAULT_OUTPUT ) : check . str_param ( output_name , 'output_name' ) if not self . solid . definition . has_output ( output_name ) : raise DagsterInvariantViolationError ( '{output_name} not defined in solid {solid}' . format ( output_name = output_name , solid = self . solid . name ) ) if self . success : for result in self . transforms : if ( result . is_successful_output and result . step_output_data . output_name == output_name ) : with self . reconstruct_context ( ) as context : value = self . _get_value ( context , result . step_output_data ) return value raise DagsterInvariantViolationError ( ( 'Did not find result {output_name} in solid {self.solid.name} ' 'execution result' ) . format ( output_name = output_name , self = self ) ) else : return None
Returns transformed value either for DEFAULT_OUTPUT or for the output
        given as output_name. Returns None if execution result isn't a success.

        Reconstructs the pipeline context to materialize value.
Returns transformed value either for DEFAULT_OUTPUT or for the output given as output_name . Returns None if execution result isn t a success .