diff --git a/files/nats_registration_listener.py b/files/nats_registration_listener.py index eb5dcaf..97250a3 100644 --- a/files/nats_registration_listener.py +++ b/files/nats_registration_listener.py @@ -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": {