Solves typing error
@@ -136,6 +136,7 @@ class AWSSNSSQSTransport(Invoker):
context['_aws_sns_sqs_received_messages'] = {k: v for k, v in context['_aws_sns_sqs_received_messages'].items() if v > time.time() - 60}
if _callback_kwargs:
+ if isinstance(message, dict):
for k, v in message.items():
if k in _callback_kwargs:
kwargs[k] = v
