Mateusz Mandera 58d9975cca embed_links: Interrupt consume() function on worker timeout. ... This fixes a bug introduced in 95b46549e1 which made the worker simply log a warning about the timeout and then continue consume()ing the event that should have also been interrupted. The idea here is to introduce an exception which can be used to interrupt the consume() process without triggering the regular handling of exceptions that happens in _handle_consume_exception.		2021-07-07 09:24:50 -07:00
..
__init__.py	Add new system for defining and running queue-processing workers	2013-09-24 20:44:15 -04:00
queue_processors.py	embed_links: Interrupt consume() function on worker timeout.	2021-07-07 09:24:50 -07:00