ci: re-fix some linter errors after a rebase
This commit is contained in:
@@ -37,7 +37,7 @@ def test_current_reasoning_effort_reads_dict_form():
|
||||
def test_hermes_model_offers_reasoning_whenever_a_pick_is_saved(tmp_path, monkeypatch):
|
||||
"""Same model ID on a new provider, or a re-pick of the current model, still gets the effort
|
||||
step (like chat /model); a flow that saves nothing does not."""
|
||||
import hermes_cli.main as main
|
||||
from hermes_cli import main
|
||||
from hermes_cli.auth import _save_model_choice
|
||||
from hermes_cli.config import load_config, save_config
|
||||
|
||||
|
||||
@@ -133,7 +133,7 @@ def test_pinned_fresh_clone_never_materializes_the_branch_tip(tmp_path):
|
||||
def test_pinned_fresh_clone_publishes_nothing_when_the_pin_is_refused(tmp_path):
|
||||
origin, _, off_branch = _pin_fixture(tmp_path)
|
||||
home = tmp_path / "home"
|
||||
result, frame = _stage(origin, home, "-Commit", off_branch)
|
||||
_, frame = _stage(origin, home, "-Commit", off_branch)
|
||||
assert frame["ok"] is False
|
||||
assert "is not on branch main" in frame["reason"]
|
||||
assert not (home / "hermes-agent").exists()
|
||||
|
||||
@@ -262,7 +262,7 @@ def test_detached_grandchild_is_killed_by_runner(tmp_path: Path) -> None:
|
||||
[sys.executable, str(repo_root / "scripts" / "run_tests_parallel.py"),
|
||||
"--paths", str(probe_dir), "-j", "1", "--file-timeout", "30"],
|
||||
cwd=probe_dir, stdout=subprocess.PIPE, stderr=subprocess.STDOUT,
|
||||
encoding="utf-8", errors="replace", timeout=60,
|
||||
encoding="utf-8", errors="replace", timeout=60, check=False,
|
||||
)
|
||||
pid = json.loads(handoff.read_text(encoding="utf-8-sig"))["pid"]
|
||||
deadline = time.monotonic() + 5.0
|
||||
|
||||
@@ -39,7 +39,7 @@ def pair():
|
||||
|
||||
|
||||
def test_unbounded_reply_retains_late_attachment_for_consumer_cleanup(pair):
|
||||
server, registry, sup, handle = pair
|
||||
server, _registry, _sup, handle = pair
|
||||
abandoned = threading.Event()
|
||||
outcomes = []
|
||||
def worker():
|
||||
@@ -58,7 +58,7 @@ def test_unbounded_reply_retains_late_attachment_for_consumer_cleanup(pair):
|
||||
|
||||
|
||||
def test_dispatch_deadline_refuses_queued_command_after_timeout(pair):
|
||||
server, registry, sup, handle = pair
|
||||
server, _registry, sup, handle = pair
|
||||
entered = threading.Event()
|
||||
def block():
|
||||
# Stall the loop past the caller's deadline but inside its +1s result grace.
|
||||
@@ -73,7 +73,7 @@ def test_dispatch_deadline_refuses_queued_command_after_timeout(pair):
|
||||
|
||||
|
||||
def test_before_send_checks_cancellation_on_supervisor_loop(pair):
|
||||
server, registry, sup, handle = pair
|
||||
server, _registry, sup, handle = pair
|
||||
entered, release, abandoned = threading.Event(), threading.Event(), threading.Event()
|
||||
failures = []
|
||||
def block():
|
||||
@@ -100,7 +100,7 @@ def test_before_send_checks_cancellation_on_supervisor_loop(pair):
|
||||
|
||||
|
||||
def test_unbounded_reply_fails_promptly_on_socket_close(pair):
|
||||
server, registry, sup, handle = pair
|
||||
server, _registry, _sup, handle = pair
|
||||
failures = []
|
||||
# This fixture replies to ordinary methods; block the connection handler on attach instead.
|
||||
def attach():
|
||||
@@ -119,8 +119,8 @@ def test_unbounded_reply_fails_promptly_on_socket_close(pair):
|
||||
|
||||
|
||||
def test_unbounded_wait_ends_when_loop_closes_with_dispatch_queued(pair, monkeypatch):
|
||||
server, registry, sup, handle = pair
|
||||
import agent.async_utils as async_utils
|
||||
_server, registry, _sup, handle = pair
|
||||
from agent import async_utils
|
||||
# A stop racing call() can close the loop before its queued dispatch runs; the
|
||||
# scheduled future then never resolves.
|
||||
real = async_utils.safe_schedule_threadsafe
|
||||
|
||||
Reference in New Issue
Block a user