Sqs-workers

Latest version: v0.5.22

Safety actively analyzes 723158 Python packages for vulnerabilities to keep your Python projects secure.

Scan your dependencies

Page 4 of 6

0.4.0

Added

- Added support for implicit context for tasks
- Added ASAP_SHUTDOWN shutdown policy to stop processing of the queue
as soon it's found empty

Fixed

- Fixed batch processor which used to reorder messages from FIFO queues

Changed

Made a refactoring of SQS environments and extracted in two separate classes
ProcessorManager and ProcessorManagerProxy.

It's changed the API of SQSEnv, so that instead of
`sqs.connect_processor(queue, 'say_hello', say_hello)` the API of
`sqs.processors.connect(queue, 'say_hello', say_hello)` has to be used.

Also overwriting "makers" after the initialization of SQSEnv needs to be done
in a different way. Instead of `sqs.fallback_processor_maker = DeadLetterProcessor`
the syntax of `sqs.processors.fallback_processor_maker = DeadLetterProcessor`
should be used instead.

0.3.7

Added

- Added custom processors and batch processors

0.3.6

Added

- Added proper support for FIFO queues by sending message deduplication id and
group id

0.3.5

Added

- Added and documented sqs.copy_processors to process dead-letter queues

0.3.4

Added

- Added ability to configure SQS environment with custom fallback processors
- Implemented DeadLetterProcessor to push back messages from dead-letter
queue to the main one.

0.3.3

Fixed

- Fixed the encoding problem with the PickleCodec, MemoryEnv and python27

Page 4 of 6

© 2025 Safety CLI Cybersecurity Inc. All Rights Reserved.