Retrieve the set of events that the module is interested in observing. Override this method if the set of events the module should watch needs to be determined dynamically, e.g., based on configuration options or other runtime conditions. Returns: set: The set of event
(self)
| 444 | return self._event_received |
| 445 | |
| 446 | def get_watched_events(self): |
| 447 | """Retrieve the set of events that the module is interested in observing. |
| 448 | |
| 449 | Override this method if the set of events the module should watch needs to be determined dynamically, e.g., based on configuration options or other runtime conditions. |
| 450 | |
| 451 | Returns: |
| 452 | set: The set of event types that this module will handle. |
| 453 | """ |
| 454 | if self._watched_events is None: |
| 455 | self._watched_events = set(self.watched_events) |
| 456 | return self._watched_events |
| 457 | |
| 458 | async def _handle_batch(self): |
| 459 | """ |