@sessioned
    def get_stream_events(self, stream, session=None):
        if session not in stream:
            stream = session.merge(stream)
        return [event.as_dict for event in stream.events]
dataset/ETHPy150Open openstack/stacktach-winchester/winchester/db/interface.py/DBInterface.get_stream_events/swapped operands of `not in`