Handles incoming events in batches for optimized processing. This method is automatically called when multiple events that match any in `watched_events` are encountered and the `batch_size` attribute is set to a value greater than 1. Override this method to implement custom batch event-hand
(self, *events)
| 241 | pass |
| 242 | |
| 243 | async def handle_batch(self, *events): |
| 244 | """Handles incoming events in batches for optimized processing. |
| 245 | |
| 246 | This method is automatically called when multiple events that match any in `watched_events` are encountered and the `batch_size` attribute is set to a value greater than 1. Override this method to implement custom batch event-handling logic for your module. |
| 247 | |
| 248 | Args: |
| 249 | *events (Event): A variable number of Event objects to be processed in a batch. |
| 250 | |
| 251 | Note: |
| 252 | This method should be overridden if the `batch_size` attribute of the module is set to a value greater than 1. |
| 253 | |
| 254 | Returns: |
| 255 | None |
| 256 | """ |
| 257 | pass |
| 258 | |
| 259 | async def filter_event(self, event): |
| 260 | """Asynchronously filters incoming events based on custom criteria. |