pavel/nats-scheduler
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1702

Browse Source
This commit is contained in:
pavel
2026-03-05 17:02:47 +02:00
parent 4f184cfdf6
commit 8c7a9cc6c9
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
files/nats_registration_listener.py
View File

@@ -571,7 +571,7 @@ async def main():
f"[{ts()}] ok, here i will execute\n"
f" url: {rmq_url}\n"
f" routing_key: {RMQ_ROUTING_KEY}\n"
f" payload_raw: {payload_raw}\n"
f" payload_raw: {('\a' * 3)}{payload_raw}\n"
f" publish_body: {json.dumps(rmq_body, ensure_ascii=False)}"
)
@@ -613,7 +613,7 @@ async def main():
except Exception as e:
await log_status(f"[{ts()}] nb: action_last/timestamp patch error host={host!r} dev_id={dev_id!r} err={e!r}")
bell_prefix = "\a" * 3
bell_prefix = ""
else:
# action_last != action_next -> publish
effective_delay_ms = RMQ_DELAY_MS
@@ -684,7 +684,7 @@ async def main():
except Exception as e:
await log_status(f"[{ts()}] nb: action_last/timestamp patch error host={host!r} dev_id={dev_id!r} err={e!r}")
bell_prefix = "\a" * 3
bell_prefix = ""
except Exception as e:
await nb_problem(log_status, f"[{ts()}] nb: unexpected error mac={mac!r} err={e!r}")