def set_pipeline_definition(self):
        """Translates the json definition and puts it on created pipeline

        Returns:
                dict: the response of the Boto3 command
        """

        if not self.pipeline_id:
            self.get_pipeline_id()

        json_def = self.datapipeline_data['json_definition']
        try:
            pipelineobjects = translator.definition_to_api_objects(json_def)
            parameterobjects = translator.definition_to_api_parameters(json_def)
            parametervalues = translator.definition_to_parameter_values(json_def)
        except translator.PipelineDefinitionError as error:
            LOG.warning(error)
            raise DataPipelineDefinitionError

        response = self.client.put_pipeline_definition(
            pipelineId=self.pipeline_id,
            pipelineObjects=pipelineobjects,
            parameterObjects=parameterobjects,
            parameterValues=parametervalues)
        LOG.debug(response)
        LOG.info("Successfully applied pipeline definition")
        return response
def set_pipeline_definition ( self ) : if not self . pipeline_id : self . get_pipeline_id ( ) json_def = self . datapipeline_data [ 'json_definition' ] try : pipelineobjects = translator . definition_to_api_objects ( json_def ) parameterobjects = translator . definition_to_api_parameters ( json_def ) parametervalues = translator . definition_to_parameter_values ( json_def ) except translator . PipelineDefinitionError as error : LOG . warning ( error ) raise DataPipelineDefinitionError response = self . client . put_pipeline_definition ( pipelineId = self . pipeline_id , pipelineObjects = pipelineobjects , parameterObjects = parameterobjects , parameterValues = parametervalues ) LOG . debug ( response ) LOG . info ( "Successfully applied pipeline definition" ) return response
Translates the json definition and puts it on created pipeline

        Returns:
                dict: the response of the Boto3 command