Call cancel_join_thread on multiprocessing queue to allow shard proce…

…ss to shutdown since it was not creater of this queue
Crowesesse · Jul 30, 2024 · f8a2a52 · f8a2a52
1 parent 4f8c026
commit f8a2a52
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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)