From 25f69f43e564b813ea532755e6ab536d40ab3f51 Mon Sep 17 00:00:00 2001 From: johnny-emp Date: Tue, 6 May 2025 02:50:24 -0700 Subject: [PATCH] catch queue delete error --- .flake8 | 3 --- pyproject.toml | 5 +---- src/emp_hooks/handlers/sqs_hooks.py | 9 +++++++-- 3 files changed, 8 insertions(+), 9 deletions(-) delete mode 100644 .flake8 diff --git a/.flake8 b/.flake8 deleted file mode 100644 index 6b0bd30..0000000 --- a/.flake8 +++ /dev/null @@ -1,3 +0,0 @@ -[flake8] -ignore = E704, W503 -max-line-length = 160 diff --git a/pyproject.toml b/pyproject.toml index e573bb0..aa2cefe 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [project] name = "emp_hooks" -version = "0.0.12" +version = "0.0.12post1" description = "emp hooks" authors = [ {name = "johnny-emp",email = "johnny@empyrealsdk.com"} @@ -50,6 +50,3 @@ filterwarnings = [ "ignore::DeprecationWarning:pytest_asyncio.*", ] asyncio_mode = "auto" - -[tool.flake8] -ignore = ["E704", "W503"] diff --git a/src/emp_hooks/handlers/sqs_hooks.py b/src/emp_hooks/handlers/sqs_hooks.py index 055264d..88c0a99 100644 --- a/src/emp_hooks/handlers/sqs_hooks.py +++ b/src/emp_hooks/handlers/sqs_hooks.py @@ -2,14 +2,16 @@ import json import os import threading -import time from typing import Callable from pydantic import ConfigDict, Field, PrivateAttr +import botocore.exceptions from emp_hooks.types import Hook from emp_hooks.utils import SQSQueue +from emp_hooks.logger import log + class SQSHooks(Hook): name: str = Field(default="SQS Hooks") @@ -78,7 +80,10 @@ async def _run(self, visibility_timeout: int = 30, loop_interval: int = 5): do_delete = func(body) if do_delete: - message.delete() + try: + message.delete() + except botocore.exceptions.ClientError as e: + log.error("Error deleting message: %s", e) await asyncio.sleep(loop_interval)