in lambdamap/core.py [0:0]
def invoke_handler(self, payload):
"""
"""
client = self.client
payload = base64.b64encode(cloudpickle.dumps(payload)).decode("ascii")
payload = json.dumps(payload)
resp = client.invoke(
FunctionName=self._lambda_arn,
InvocationType="RequestResponse",
Payload=payload
)
resp_bytes = resp["Payload"].read()
if "FunctionError" in resp:
result = resp_bytes
else:
result = cloudpickle.loads(resp_bytes)
return result