NousResearch/atropos
1
0
Fork 0
mirror of https://github.com/NousResearch/atropos.git synced 2026-05-02 17:45:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

chore: enhance controller logging for decision transparency

Browse source
This commit is contained in:
RUFFY-369 2026-04-03 02:07:12 +05:30
parent ce2d3abb2c
commit 2f31b86a7b
1 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

9
atroposlib/orchestration/controller.py
View file

@ -38,22 +38,24 @@ class ScalingController:
# 1. Check cooldown
if now - self.last_action_timestamp < self.cooldown_seconds:
remaining = int(self.cooldown_seconds - (now - self.last_action_timestamp))
logger.debug(f"Controller: In cooldown ({remaining}s remaining). Holding at {self.current_desired} actors.")
return self.current_desired
# 2. Sensitivity check (Hysteresis)
# If work is roughly satisfying target, don't change anything.
if abs(pressure - self.target_pressure) < self.scaling_threshold:
logger.debug(f"Controller: Pressure {pressure:.2f} within threshold of {self.target_pressure}. No action.")
return self.current_desired
# 3. Calculate target
# Target = Current * (Current_Pressure / Ideal_Pressure)
# This is a dampened proportional controller.
raw_target = math.ceil(current_actors * (pressure / self.target_pressure))
# 4. Apply step constraints (Rate Limiting)
# Don't add/remove more than max_step_change in a single move.
diff = raw_target - current_actors
if abs(diff) > self.max_step_change:
logger.info(f"Controller: Step change {diff} exceeds max_step_change ({self.max_step_change}). Capping.")
raw_target = current_actors + (self.max_step_change if diff > 0 else -self.max_step_change)
# 5. Apply world bounds
@ -62,6 +64,7 @@ class ScalingController:
if final_target != current_actors:
self.last_action_timestamp = now
self.current_desired = final_target
logger.info(f"Controller DECISION: Scale {current_actors} -> {final_target} (Pressure: {pressure:.2f})")
direction = "UP" if final_target > current_actors else "DOWN"
logger.info(f"Controller DECISION: Scale {direction} {current_actors} -> {final_target} (Pressure: {pressure:.2f})")
return final_target