Bogdan Popa

This isn't currently possible because groups don't have any notion of a completion callback. i.e. to be able to use a group inside a pipeline you'd have to be able...

You can't get an accurate queue size from RMQ via the AMQP protocol because the number of received-but-not-acknowledged messages in a queue are not reported so I don't think this...

I should mention I definitely don't have the time to implement this right now so if that sounds good to you then please go ahead and implement it!

@gjeusel group completion callbacks were added in https://github.com/Bogdanp/dramatiq/pull/150/files , but I never got a chance to document them. More work is needed to get this integrated with pipelines, but if...

I'm unlikely to work on it any time soon, because I don't need anything like it. I'd be happy to review and merge if someone does the work, though.

I plan to do this as part of a 2.0 release with small breaking changes like this one at some point in the future.

This behavior is expected so things are working as intended. If workers die for any reason, the main process restarts everything. > Worker with PID 13 exited unexpectedly (code -9)....

Yes, but I don't have time right now and probably won't for a while. Sorry!

Yes, I would accept this as long as you update all the brokers and document the behaviour.

I'm reluctant to make this change since it's technically breaking and, if we were to go in this direction, then I'd rather just make the argument required than have it...