From c22f321115135263783811f1ce4cbadb2295ff37 Mon Sep 17 00:00:00 2001 From: Zack Cerza Date: Thu, 22 Jan 2026 13:19:19 -0700 Subject: [PATCH] node cleanup output --- scripts/node_cleanup.py | 19 +++++++++---------- 1 file changed, 9 insertions(+), 10 deletions(-) diff --git a/scripts/node_cleanup.py b/scripts/node_cleanup.py index 5d474b7c8..42f7392e3 100755 --- a/scripts/node_cleanup.py +++ b/scripts/node_cleanup.py @@ -19,6 +19,7 @@ def main(): handler.setFormatter( logging.Formatter('%(message)s') ) + log.info("Checking for stale locks...") try: stale = query.find_stale_locks(args.owner) except Exception: @@ -35,17 +36,15 @@ def main(): ) continue by_owner.setdefault(node['locked_by'], []).append(node) - if args.dry_run: - log.info("Would attempt to unlock:") - for owner, nodes in by_owner.items(): - for node in nodes: - node_job = node['description'].replace( - config.archive_base, config.results_ui_server) - log.info(f"{node['name']}\t{node_job}") - else: - for owner, nodes in by_owner.items(): + log.info(f"Unlocking {len(stale)} nodes...") + for owner, nodes in by_owner.items(): + for node in nodes: + node_job = node['description'].replace( + config.archive_base, config.results_ui_server).replace('//', '/') + log.info(f"{node['name']}\t{node_job}") + if not args.dry_run: ops.unlock_safe([node["name"] for node in nodes], owner) - log.info(f"unlocked {len(stale)} nodes") + log.info(f"Unlocked {len(stale)} nodes") def parse_args(argv): parser = argparse.ArgumentParser( -- 2.47.3