@sessioned
    def stream_ready_to_fire(self, stream, timestamp, session=None):
        if stream not in session:
            session.add(stream)
        stream.fire_timestamp = timestamp
dataset/ETHPy150Open openstack/stacktach-winchester/winchester/db/interface.py/DBInterface.stream_ready_to_fire/original