chore: fix body handling in sqs_handler

agentcoinorg · Feb 18, 2024 · 7d6a60d · 7d6a60d
1 parent 3e18fa0
commit 7d6a60d
Showing 1 changed file with 3 additions and 7 deletions.
diff --git a/workers/fund_public_goods/events.py b/workers/fund_public_goods/events.py
@@ -48,14 +48,10 @@ def sqs_handler(sqs_event: SQSEvent, _: Context):
 
     for record in sqs_event['Records']:
         message_body = record['body']
-        print("message body")
-        print(message_body)
-        message: dict[str, Any] = json.loads(str(message_body))
-        print("message after json loads")
-        print(message)
+        message: dict[str, Any] = json.loads(message_body)
         events.append(EventData(
-            name=message["name"],
-            payload=message["payload"]
+            name=message[0],
+            payload=message[1]
         ))
 
     for event in events: