Mateusz Mandera d200e3547f 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:25:13 -07:00

..

__init__.py

…

queue_processors.py

embed_links: Interrupt consume() function on worker timeout.

2021-07-07 09:25:13 -07:00