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()