From f8a2a523fbc69078f3f4fefba6bdac688ab03ad7 Mon Sep 17 00:00:00 2001 From: Nathan Crowe Date: Mon, 29 Jul 2024 21:24:00 -0400 Subject: [PATCH] Call cancel_join_thread on multiprocessing queue to allow shard process to shutdown since it was not creater of this queue --- src/kinesis/consumer.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/kinesis/consumer.py b/src/kinesis/consumer.py index c1e49d5..f5441f4 100644 --- a/src/kinesis/consumer.py +++ b/src/kinesis/consumer.py @@ -70,6 +70,8 @@ def loop(self): def end(self): """End of the main loop""" + self.record_queue.cancel_join_thread() + self.error_queue.cancel_join_thread() log.info("Shard reader for %s stoping", self.shard_id)