

def handle_events(self, events, env):
    keys = [key for key in self.env_keys]
    self.pending_notifications = []
    for key in env:
        self.pending_notifications.extend(env.get(key, []))
    return events

dataset/ETHPy150Open openstack/stacktach-winchester/winchester/pipeline_handler.py NotabeneHandler.handle_events/VarMisuse@36/40 `keys`->`env`