cmartmos
cmartmos
The issue arises because of unexpected application crashes and then the event loop raises the given error while closing
An ugly patch to the issue was the following ```py schema = MySchema() # create internal topic manually internal_topic = app.topic('counter-internal-topic', schema=schema, internal=True) @app.agent() async def counter(stream): async for event...
@dabdada could you extend stream.group_by to accept schemas as an argument?