1.1.0

joowani released this 13 Dec 14:24

38c5ca7

Added Queue.enqueue_with_key(key, func, *args, **kwargs) method for adding jobs with specific Kafka message keys for sequential processing.
Fixed a bug where consumer offsets are committed when jobs fail.
Minor documentation updates.

Assets 2