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

20:42

Browse Source
This commit is contained in:
pavel
2025-11-05 20:42:39 +02:00
parent f2600d2bb6
commit e48e2f28fc
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

@@ -5,7 +5,7 @@ NATS Registration Listener (fox100 + NetBox hostname/upgrade_cmd lookup + timing
- One device GET (status + tags + custom_fields.upgrade_cmd), no duplicate fetch
- If fox100 and upgrade_cmd present -> prepend 3x ASCII BEL to stdout line
- Publish logic for fox100:
* upgrade_cmd empty/absent -> publish with task_name="ot-updater"
* upgrade_cmd empty/absent -> publish with task_name="sot-updater"
* upgrade_cmd present -> publish with task_name="sot-updater-upgradecmd" (+ 3 BELs)
- Keeps: nb_problems counter, timings, iface_id diagnostics, same formatting
"""
@@ -352,7 +352,7 @@ async def main():
# NEW LOGIC:
# - If host known:
# * upgrade_cmd empty/absent -> publish with task_name="ot-updater"
# * upgrade_cmd empty/absent -> publish with task_name="sot-updater"
# * upgrade_cmd present -> publish with task_name="sot-updater-upgradecmd" and ring 3 BELs
if host:
try:
@@ -368,7 +368,7 @@ async def main():
except Exception:
has_upgrade_cmd = False
task_name = "sot-updater-upgradecmd" if has_upgrade_cmd else "ot-updater"
task_name = "sot-updater-upgradecmd" if has_upgrade_cmd else "sot-updater"
rmq_body = {
"properties": {