Fix async invocation in Python 3 (#1006)

See Miserlou/Zappa#1331 Co-authored-by: hellno <[email protected]> Co-authored-by: javulticat <[email protected]>
zappa · Dec 29, 2021 · 86a471c · 86a471c
1 parent ddc3fbb
commit 86a471c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/zappa/asynchronous.py b/zappa/asynchronous.py
@@ -187,7 +187,7 @@ def _send(self, message):
         Given a message, directly invoke the lamdba function for this task.
         """
         message["command"] = "zappa.asynchronous.route_lambda_task"
-        payload = json.dumps(message).encode("utf-8")
+        payload = json.dumps(message)
         if len(payload) > LAMBDA_ASYNC_PAYLOAD_LIMIT:  # pragma: no cover
             raise AsyncException("Payload too large for async Lambda call")
         self.response = self.client.invoke(
@@ -259,7 +259,7 @@ def _send(self, message):
         Given a message, publish to this topic.
         """
         message["command"] = "zappa.asynchronous.route_sns_task"
-        payload = json.dumps(message).encode("utf-8")
+        payload = json.dumps(message)
         if len(payload) > LAMBDA_ASYNC_PAYLOAD_LIMIT:  # pragma: no cover
             raise AsyncException("Payload too large for SNS")
         self.response = self.client.publish(TargetArn=self.arn, Message=payload)