Searched refs:event_obj (Results 1 – 1 of 1) sorted by relevance
84 event_obj = self._rpc_client.eventWait(60000, timeout=120)93 if not event_obj:95 elif 'name' not in event_obj:96 self.log.error('Received Malformed event {}'.format(event_obj))99 event_name = event_obj['name']109 (self._handlers[event_name].__name__, event_obj))110 self.handle_subscribed_event(event_obj, event_name)112 self.log.debug('Queuing event: %r' % event_obj)115 self._event_dict[event_name].put(event_obj)118 q.put(event_obj)[all …]