Asynchronously handles incoming events that the module is configured to watch. This method is automatically invoked when an event that matches any in `watched_events` is encountered during a scan. Override this method to implement custom event-handling logic for your module. Args:
(self, event, **kwargs)
| 225 | return True |
| 226 | |
| 227 | async def handle_event(self, event, **kwargs): |
| 228 | """Asynchronously handles incoming events that the module is configured to watch. |
| 229 | |
| 230 | This method is automatically invoked when an event that matches any in `watched_events` is encountered during a scan. Override this method to implement custom event-handling logic for your module. |
| 231 | |
| 232 | Args: |
| 233 | event (Event): The event object containing details about the incoming event. |
| 234 | |
| 235 | Note: |
| 236 | This method should be overridden if the `batch_size` attribute of the module is set to 1. |
| 237 | |
| 238 | Returns: |
| 239 | None |
| 240 | """ |
| 241 | pass |
| 242 | |
| 243 | async def handle_batch(self, *events): |
| 244 | """Handles incoming events in batches for optimized processing. |