bugfix(aws-plugin-signal-consume): always json.loads() message body m…

…essage
Netflix · Dec 10, 2024 · 85b3c07 · 85b3c07
1 parent baf139d
commit 85b3c07
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/dispatch/plugins/dispatch_aws/plugin.py b/src/dispatch/plugins/dispatch_aws/plugin.py
@@ -82,9 +82,8 @@ def consume(self, db_session: Session, project: Project) -> None:
                     if message_attributes.get("compressed", {}).get("Value") == "zlib":
                         # Message is compressed, decompress it
                         message_body_message = decompress_json(message_body_message)
-                        signal_data = json.loads(message_body_message)
-                    else:
-                        signal_data = message_body_message
+
+                    signal_data = json.loads(message_body_message)
                 except Exception as e:
                     log.exception(f"Unable to extract signal data from SQS message: {e}")
                     continue