From 61265b43f4a75cb64ac7f8ef00dbdd6c86b13739 Mon Sep 17 00:00:00 2001 From: JamesAbel Date: Wed, 15 Apr 2026 15:31:03 -0700 Subject: [PATCH 1/3] Tolerate no signal source --- awsimple/__version__.py | 2 +- awsimple/pubsub.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/awsimple/__version__.py b/awsimple/__version__.py index 51c618e..81dcf89 100644 --- a/awsimple/__version__.py +++ b/awsimple/__version__.py @@ -1,7 +1,7 @@ __application_name__ = "awsimple" __title__ = __application_name__ __author__ = "abel" -__version__ = "7.2.0" +__version__ = "7.2.1" __author_email__ = "j@abel.co" __url__ = "https://github.com/jamesabel/awsimple" __download_url__ = "https://github.com/jamesabel/awsimple" diff --git a/awsimple/pubsub.py b/awsimple/pubsub.py index f927680..a7004d0 100644 --- a/awsimple/pubsub.py +++ b/awsimple/pubsub.py @@ -247,7 +247,7 @@ def run(self): message = json.loads(message_string) self.sub_callback(message) sqs_metadata.update_table_mtime() - except Empty: + except Empty, RuntimeError: pass # no message if self._new_event.wait(self._new_event_wait_time): # timeout in case the new event technique fails From 9f9ab647c8234beb72acf3a514cc060c4ce1dc6a Mon Sep 17 00:00:00 2001 From: JamesAbel Date: Wed, 15 Apr 2026 15:34:33 -0700 Subject: [PATCH 2/3] Tolerate no SQS signal source --- awsimple/pubsub.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/awsimple/pubsub.py b/awsimple/pubsub.py index a7004d0..47919e1 100644 --- a/awsimple/pubsub.py +++ b/awsimple/pubsub.py @@ -234,7 +234,7 @@ def run(self): message = self._pub_queue.get(False) message_string = json.dumps(message) sns.publish(message_string) - except Empty: + except Empty, RuntimeError: pass # sub From 7c6171bbe7bd1be653366c410c3f0bd75ffe6c13 Mon Sep 17 00:00:00 2001 From: JamesAbel Date: Wed, 15 Apr 2026 15:39:18 -0700 Subject: [PATCH 3/3] Tolerate no SQS signal source --- awsimple/pubsub.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/awsimple/pubsub.py b/awsimple/pubsub.py index 47919e1..7de3240 100644 --- a/awsimple/pubsub.py +++ b/awsimple/pubsub.py @@ -234,8 +234,10 @@ def run(self): message = self._pub_queue.get(False) message_string = json.dumps(message) sns.publish(message_string) - except Empty, RuntimeError: + except Empty: pass + except RuntimeError as e: + log.info(f"SQS,{self.sqs_queue_name=},{e}") # sub if sqs_thread is not None: @@ -247,8 +249,10 @@ def run(self): message = json.loads(message_string) self.sub_callback(message) sqs_metadata.update_table_mtime() - except Empty, RuntimeError: + except Empty: pass # no message + except RuntimeError as e: + log.info(f"SQS,{self.sqs_queue_name=},{e}") if self._new_event.wait(self._new_event_wait_time): # timeout in case the new event technique fails self._new_event.clear()