

def _db(self, obj):
    _db = Db(obj.container.get_absolute_url(), obj.container.id)
    pubsub = _db.object().pubsub()
    pubsub.subscribe(_db.key)
    return pubsub

dataset/ETHPy150Open opps/opps/opps/contrib/notifications/views.py AsyncServer._db/original