def get_pipeline(self):
        raise NotImplementedError
Return a new pipeline instance (bound to this connection).
dataset/ETHPy150Open disqus/nydus/nydus/db/backends/base.py/BaseConnection.get_pipeline