diff --git a/src/message_processor.py b/src/message_processor.py index 63115db..c35c8ba 100644 --- a/src/message_processor.py +++ b/src/message_processor.py @@ -1,4 +1,5 @@ from loguru import logger +import json # context @@ -64,7 +65,7 @@ def process_message(box_name, topic_key, payload, context): logger.info(f"[{box_name}] Result published on '{publish_topic}': {status} {result_message}") statustext_topic = f"{context['statustext_topic_prefix']}{box['label']}" - context['client'].publish(statustext_topic, f"{local_context}") + context['client'].publish(statustext_topic, json.dumps(local_context)) logger.info(f"[{box_name}] Local context after: {local_context}") except Exception as e: