Override run to filter out None events from _dispatch_event filtering.
(self, input)
| 245 | return super()._dispatch_event(event) |
| 246 | |
| 247 | async def run(self, input): |
| 248 | """Override run to filter out None events from _dispatch_event filtering.""" |
| 249 | async for event in super().run(input): |
| 250 | if event is not None: |
| 251 | yield event |
| 252 | |
| 253 | async def _handle_single_event( |
| 254 | self, event: Any, state: State |