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..7de3240 100644 --- a/awsimple/pubsub.py +++ b/awsimple/pubsub.py @@ -236,6 +236,8 @@ def run(self): sns.publish(message_string) except Empty: pass + except RuntimeError as e: + log.info(f"SQS,{self.sqs_queue_name=},{e}") # sub if sqs_thread is not None: @@ -249,6 +251,8 @@ def run(self): sqs_metadata.update_table_mtime() 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()