Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
78a68f9009
|
|||
fbb9aa6665
|
@ -1,4 +1,5 @@
|
||||
from loguru import logger
|
||||
import json
|
||||
|
||||
|
||||
# context
|
||||
@ -63,8 +64,8 @@ def process_message(box_name, topic_key, payload, context):
|
||||
context['client'].publish(publish_topic, result_message)
|
||||
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}")
|
||||
statustext_topic = f"{context['statustext_topic_prefix']}{box['label']}"
|
||||
context['client'].publish(statustext_topic, json.dumps(local_context))
|
||||
|
||||
logger.info(f"[{box_name}] Local context after: {local_context}")
|
||||
except Exception as e:
|
||||
|
Reference in New Issue
Block a user