zerafachris

@matheusmota @Midnighter Any updates on Min.IO? Maybe you can share your experience? I am currently considering giving quilt a go, but only have mio.io available

FPS - Fast Python Streaming

@wbarnha @patkivikram I tested out `app._crash()`, and I think this is not producing the expected behaviour. I tried failing an app using 'raise ValueError('Force fail')' and the agent goes into...

@hlacikd We stop our agents with agent_stopper. See `https://github.com/faust-streaming/faust/pull/329`

@ekerstens This is the **agent_1**: ``` @app.agent(topics.source_topic, sink=[topics.predict_sink]) async def predict(stream: StreamT): async for record in stream.noack().events(): if record.value.get('customer_id') == 5: raise Exception('customer_id == 5') yield record.value await stream.ack(record) ```...

Hi @chase2981 What did you end up pursuing at the end?

Hi @adamschmidt , the feature handles the metadata object inside of PostGres. I can use **_db_schema_** instead of **_registry_schema_** no worries, however the class model is not being used. All...

@adchia could you kindly have a look

/assign @achals

Conflicts have been resolved. Can we get a review