Skip to content

Commit

Permalink
Add more sync debugging for pubsub
Browse files Browse the repository at this point in the history
  • Loading branch information
laffra committed Jan 26, 2024
1 parent 0eb6fa0 commit 3e83801
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion ltk/pubsub.py
Original file line number Diff line number Diff line change
Expand Up @@ -68,8 +68,9 @@ def match(self, message, receiver, receiver_topic, handler):
if message.topic == receiver_topic and message.sender != receiver:
handled = False
if isinstance(handler, str):
print("[PUBSUB] sync handle:", handler, message.topic, str(message.data)[:64])
print("[PUBSUB] sync handle:", message.topic, str(message.data)[:64])
handled = workers[handler].sync.handler(message.sender, message.topic, json.dumps(message.data))
print("[PUBSUB] sync handled:", handled, message.topic, str(message.data)[:64])
else:
print("[PUBSUB]: match locally:", handler, message.topic, str(message.data)[:64])
handler(message.data)
Expand Down

0 comments on commit 3e83801

Please sign in to comment.