From 2d36ed6991a08d0b92416e997c0d71563c95e5a3 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Torma=20Krist=C3=B3f?= Date: Thu, 30 Apr 2020 00:17:16 +0200 Subject: [PATCH] send json dict to mq --- src/resources.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/resources.py b/src/resources.py index 62ba783..ea1e2ec 100644 --- a/src/resources.py +++ b/src/resources.py @@ -79,7 +79,7 @@ class SampleResource(Resource): rabbitmq_channel.basic_publish( exchange=RABBITMQ_EXCHANGE, routing_key='feature', - body=generated_tag) + body=json.dumps({'tag': generated_tag}).encode('utf-8')) except Exception as e: LOGGER.exception(e) db.session.rollback()