1
88%
main: 88%

Ran 17 May 2026 02:26PM UTC

Files 948

Run time 18s

Badge

Embed ▾

Committed 17 May 2026 02:17PM UTC coverage: 87.784% (+0.1%) from 87.688%

Job # 25993302793.1

Build Type

push

github

Committed by

web-flow

Commit Message

Fix AWS SNS/SQS worker shutdown hang on out_queue back-pressure (#1480)

* Fix AWS SNS/SQS worker shutdown hang on out_queue back-pressure

SQSSendThread.send_entries, SNSPublishThread.run, and
ConsumerProducerFinalThread.run all called out_queue.put() with no
timeout after a successful upstream operation. If the downstream queue
was full at that moment, the thread blocked forever without re-checking
stop_event, so BaseConsumer.run could not join it and the worker process
hung after the run loop raised (e.g. a SQL connection error in a
preprocessor).

Loop the put with timeout=1 and bail out if stop_event is set, mirroring
the pattern already used in SQSReceiveThread. On shutdown the receipt
handle is dropped; SQS visibility timeout will redeliver the message.

* Add tests for out_queue.put shutdown behavior in worker threads

Cover the three sites of the previous shutdown-hang bug:

- SQSSendThread.send_entries: drops the receipt handle when the
  out_queue is full and stop_event is set, and retries otherwise
- SNSPublishThread.run: drops the receipt handle on the same condition
- ConsumerProducerFinalThread.run: drops the receipt handle on the
  same condition

All four tests mock the out_queue to raise queue.Full so they run in
milliseconds rather than the 1 s timeout cycle.

Coverage Stats

45264 of 51563 relevant lines covered (87.78%)

0.88 hits per line

zentralopensource / zentral / 25993302793 / 1
88%
main: 88%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

Source Files on job 25993302793.1

zentralopensource / zentral / 25993302793 / 1 88% main: 88%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

Source Files on job 25993302793.1

zentralopensource / zentral / 25993302793 / 1
88%
main: 88%

README BADGES
x