Defer config.py side effects into initialize(), bump version (v0.6.2)

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: ambled

CHANGELOG.md

@@ -2,6 +2,11 @@
 
 ## [Unreleased]
 
+## [0.6.2] - 2026-02-17
+
+### Changed
+- Deferred `config.py` import-time side effects into explicit `initialize()` function
+
 ## [0.6.1] - 2026-02-16
 
 ### Changed

src/wnm/__init__.py

@@ -1,3 +1,3 @@
 """A service to manage a cluster of decentralized Autonomi nodes"""
 
-__version__ = "0.6.1"
+__version__ = "0.6.2"

src/wnm/__main__.py

@@ -8,16 +8,8 @@
 
 from sqlalchemy import insert, select
 
-from wnm import __version__
-from wnm.config import (
-    LOCK_FILE,
-    S,
-    apply_config_updates,
-    config_updates,
-    engine,
-    machine_config,
-    options,
-)
+from wnm import __version__, config
+from wnm.config import LOCK_FILE, apply_config_updates
 from wnm.decision_engine import DecisionEngine
 from wnm.executor import ActionExecutor
 from wnm.migration import detect_port_ranges_from_nodes, survey_machine
@@ -69,7 +61,7 @@ def signal_handler(signum, frame):
 
 
 # Make a decision about what to do (new implementation using DecisionEngine)
-def choose_action(machine_config, metrics, dry_run):
+def choose_action(machine_config, metrics, dry_run, options, S):
     """Plan and execute actions using DecisionEngine and ActionExecutor.
 
     This function now acts as a thin wrapper around the new decision engine
@@ -79,6 +71,8 @@ def choose_action(machine_config, metrics, dry_run):
         machine_config: Machine configuration dictionary
         metrics: Current system metrics
         dry_run: If True, log actions without executing
+        options: Parsed CLI options
+        S: Database session factory
 
     Returns:
         Dictionary with execution status
@@ -119,22 +113,22 @@ def choose_action(machine_config, metrics, dry_run):
     )
 
     # Use the new DecisionEngine to plan actions
-    engine = DecisionEngine(
+    de = DecisionEngine(
         machine_config,
         metrics,
         is_init=is_init,
         should_survey_init=should_survey_init,
         enable_upgrade=getattr(options, "enable_upgrade", False),
     )
-    actions = engine.plan_actions()
+    actions = de.plan_actions()
 
     # Log the computed features for debugging
     if (
         options.show_decisions
         or options.v
         or logging.getLogger().isEnabledFor(logging.DEBUG)
     ):
-        logging.info(json.dumps(engine.get_features(), indent=2))
+        logging.info(json.dumps(de.get_features(), indent=2))
 
     # Inject transient action delay override into machine_config if provided
     # Priority: --interval takes precedence over --this_action_delay
@@ -155,6 +149,15 @@ def choose_action(machine_config, metrics, dry_run):
 
 
 def main():
+    config.initialize()
+
+    # Bind locals from config module (set by initialize())
+    options = config.options
+    S = config.S
+    engine = config.engine
+    machine_config = config.machine_config
+    config_updates = config.config_updates
+
     # Handle --version flag (before any lock file or database checks)
     if options.version:
         print(f"wnm version {__version__}")
@@ -443,7 +446,7 @@ def main():
             count=options.count if hasattr(options, "count") else 1,
         )
     else:
-        this_action = choose_action(local_config, metrics, options.dry_run)
+        this_action = choose_action(local_config, metrics, options.dry_run, options, S)
 
     logging.info("Action: " + json.dumps(this_action, indent=2))