diff --git a/awd/cli.py b/awd/cli.py
index 30ead0a..133d1f2 100644
--- a/awd/cli.py
+++ b/awd/cli.py
@@ -267,7 +267,7 @@ def listen(
                 .get("PackageID", {})
                 .get("StringValue")
             )
-            if "'ResultType': 'error'" in message["Body"]:
+            if '"ResultType": "error"' in message.get("Body"):
                 logger.error(f'DOI: {doi}, Result: {message.get("Body")}')
                 sqs.delete(
                     ctx.obj["sqs_base_url"],