def _generate_tfx_ir(self, pipeline: tfx_pipeline.Pipeline) -> Optional[pipeline_pb2.Pipeline]:
    result = self._tfx_compiler.compile(pipeline)
    logging.info('Generated pipeline:\n %s', result)
    return result
def _generate_tfx_ir(self, pipeline: tfx_pipeline.Pipeline) -> Optional[pipeline_pb2.Pipeline]:
    result = self._tfx_compiler.compile(pipeline)
    logging.info('Generated pipeline:\n %s', result)
    return result