Andrew Graham-Yooll

Im not sure I fully understand. Would something as simple as `create_subscription(*args, **kwargs)` solve this?

Interesting. What are you thinking exactly? You would want to encode an Avro schema to json? Or you would want to send Avro over RPC to google? The first option...

@antoniobusrod @jonasae Will this still be necessary for any apm integration?

I have no issues with this as I have heard this feature request from a number of users.

This is an interesting feature. I would too like to be able to grab the opening times data. Any idea what it would take to do this? Im thinking if...

Yeah, that could work. You are thinking of POSTing all the returned data to a field on the model and then the user can do whatever he/she wants with it...

Another extension to this is something where the Callback deserialize function could be configurable. Something like: ``` def deserialize_func(message): return message @sub(topic='my-topic', deserialize=deserialize_func): def handle_upload(data, **kwargs): print('Handling data', data) ```...

Id say both solutions are identical. In the end they are callables. You could imagine passing a function, class or lambda in there would be perfectly feasible. And they would...

Curious about the scope of this. Is this just making the sub async compatible, or the worker as well? I havent delved into it, but do you know if the...

> What are the tradeoffs of making the worker async-compatible vs just the sub? The subscriptions are essentially callbacks that are run within the worker. As such, a naive approach...