fix #141: correct SQS messages processing (#142)

Lancetnik · Jan 15, 2024 · 4d47202 · 4d47202
1 parent 5cc6c65
commit 4d47202
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/propan/__about__.py b/propan/__about__.py
@@ -2,7 +2,7 @@
 
 from unittest.mock import Mock
 
-__version__ = "0.1.5.25"
+__version__ = "0.1.5.26"
 
 
 INSTALL_MESSAGE = (

diff --git a/propan/brokers/sqs/sqs_broker.py b/propan/brokers/sqs/sqs_broker.py
@@ -364,6 +364,7 @@ async def _consume(self, queue_url: str, handler: Handler) -> NoReturn:
                         connected = True
 
                     messages = r.get("Messages", [])
+                    has_trash_messages = False
                     for msg in messages:
                         try:
                             await handler.callback(msg, True)

diff --git a/pyproject.toml b/pyproject.toml
@@ -46,7 +46,7 @@ classifiers = [
 dynamic = ["version"]
 
 dependencies = [
-    "fast-depends>=2.1.1",
+    "fast-depends>=2.1.1,<2.2.0",
     "watchfiles",
     "typer",
     "uvloop>=0.14.0,!=0.15.0,!=0.15.1; sys_platform != 'win32' and (sys_platform != 'cygwin' and platform_python_implementation != 'PyPy')",
@@ -250,4 +250,4 @@ omit = [
     '*/__main__.py',
     '*/__init__.py',
     '*/annotations.py',
-]
+]