@sessioned
    def purge_stream(self, stream, session=None):
        if session not in stream:
            session.add(stream)
        session.delete(stream)
dataset/ETHPy150Open openstack/stacktach-winchester/winchester/db/interface.py/DBInterface.purge_stream/swapped operands of `not in`