Teknium
f6938b37f3
tools/terminal_tool.py: drop 30 pure re-export names (lifecycle/config/backends/
sudo/guards/result/interrupt/utils/_DockerEnvironment/is_managed_tool_gateway_ready)
and the noqa-F401 comments on the 25 names the facade itself uses. Sibling modules
(terminal_tool_backends/_result/_sudo/_lifecycle, environments/base, process_registry)
that read removed names through the facade now import from the defining module.
tools/environments/base.py: drop 11 re-exports (base_output/base_session_env/
path_utils) and the BaseEnvironment.stop() compat alias (no in-tree caller; the
lifecycle hasattr(env, 'stop') fallback stays for third-party envs).
tools/environments/docker.py: drop 1 re-export + the re-export comment.
Callers/tests repointed to tools.terminal_tool_{lifecycle,backends,sudo,config,
guards,result}, tools.interrupt, tools.environments.{base_output,base_session_env,
path_utils}.
59 lines
2.0 KiB
Python
59 lines
2.0 KiB
Python
"""Idle cron ticks must not load config (#33612 salvage).
|
|
|
|
The gateway's built-in ticker calls tick(verbose=False) every 60s. Before
|
|
the fix, idle ticks (no due jobs) fell through the verbose-only early
|
|
return and paid a full load_config() + worker-pool resolution per tick.
|
|
The fix returns early on ANY idle tick while preserving the post-tick MCP
|
|
orphan sweep that main intentionally runs even when nothing is due.
|
|
"""
|
|
|
|
from __future__ import annotations
|
|
|
|
from unittest.mock import patch
|
|
|
|
import cron.scheduler as scheduler_mod
|
|
|
|
|
|
def _run_idle_tick(**kwargs):
|
|
"""Run tick() with no due jobs; return (load_config_called, sweep_called)."""
|
|
calls = {"load_config": 0, "sweep": 0}
|
|
|
|
def _fake_load_config(*a, **k):
|
|
calls["load_config"] += 1
|
|
return {}
|
|
|
|
def _fake_sweep():
|
|
calls["sweep"] += 1
|
|
|
|
with (
|
|
patch.object(scheduler_mod, "get_due_jobs", return_value=[]),
|
|
patch.object(scheduler_mod, "load_config", side_effect=_fake_load_config),
|
|
patch(
|
|
"tools.mcp_tool_lifecycle._kill_orphaned_mcp_children",
|
|
side_effect=_fake_sweep,
|
|
),
|
|
):
|
|
rc = scheduler_mod.tick(verbose=kwargs.get("verbose", False))
|
|
return rc, calls
|
|
|
|
|
|
class TestIdleTickSkipsConfigLoad:
|
|
def test_idle_nonverbose_tick_skips_load_config(self):
|
|
"""Gateway-style tick(verbose=False) with no due jobs: no config load."""
|
|
rc, calls = _run_idle_tick(verbose=False)
|
|
assert rc == 0
|
|
assert calls["load_config"] == 0, (
|
|
"idle tick must not load config (was loading every 60s in the gateway ticker)"
|
|
)
|
|
|
|
def test_idle_verbose_tick_skips_load_config(self):
|
|
rc, calls = _run_idle_tick(verbose=True)
|
|
assert rc == 0
|
|
assert calls["load_config"] == 0
|
|
|
|
def test_idle_tick_still_sweeps_mcp_orphans(self):
|
|
"""The idle-tick orphan sweep is intentional on main — must survive."""
|
|
rc, calls = _run_idle_tick(verbose=False)
|
|
assert rc == 0
|
|
assert calls["sweep"] == 1, "idle tick must still reap orphaned MCP children"
|