Comment 1 for bug 589413

Revision history for this message
Alex Parenteau (aubonbeurre) wrote :

I agree somewhat, but I observed in our project that we would instead prefer to have a deferred that one can trigger to cancel the queue.get() (and therefore cancel the watcher).

This would require to use something like:

defer.DeferredList((watch_children, stop_get), fireOnOneCallback=True, fireOnOneErrback=True)

So one could stop the get call by issuing:

queue.stop_get.errback(Failure(QueueStopGet("Quit")))