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

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