From 488aedbcad1f1fe43ec95f26f1246d2cfb26355d Mon Sep 17 00:00:00 2001 From: host Date: Mon, 2 Nov 2026 03:39:40 +0000 Subject: [PATCH] code-to10 v6 A14 batch2: test E402/F401 cleanup plus touched-file residual E,F cleanup MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit (cherry picked from commit 1db02545f74c96b3b92be4fc32954659cec1f814) Reconcile-conflict: A14b E402 imports referencing cloud.handler_core (does not exist here; core methods live in server.py) — kept HEAD imports with incoming's noqa: E402 markers, dropped the unused core_mod import (verified unused elsewhere in both files). --- cloud/tests/test_attempt_hook.py | 2 -- cloud/tests/test_audit_loop_driver.py | 6 ------ cloud/tests/test_audit_pushback.py | 2 -- cloud/tests/test_cost_quota.py | 1 - cloud/tests/test_coverage85_server.py | 5 +---- cloud/tests/test_coverage85_worker.py | 4 ++-- cloud/tests/test_full_auto.py | 1 - cloud/tests/test_longfunc_remaining.py | 1 - cloud/tests/test_tamper_ledger.py | 9 ++++----- cloud/tests/test_v2cov_gaps_a.py | 16 ++++++---------- cloud/tests/test_v2cov_gaps_b1.py | 5 ++--- cloud/tests/test_v2cov_gaps_d1.py | 4 ++-- cloud/tests/test_v2cov_gaps_d2.py | 4 ++-- cloud/tests/test_v2cov_gaps_d4.py | 4 ++-- cloud/tests/test_v2cov_marker_pure.py | 2 +- cloud/tests/test_v2cov_server_handlers.py | 8 +++----- cloud/tests/test_v2cov_server_handlers2.py | 7 +++---- cloud/tests/test_v2cov_server_handlers3.py | 6 ++---- cloud/tests/test_v2cov_server_handlers4.py | 2 +- cloud/tests/test_v2cov_server_handlers5.py | 4 +--- cloud/tests/test_v2cov_server_handlers6.py | 8 ++++---- cloud/tests/test_v2cov_server_handlers7.py | 6 +++--- cloud/tests/test_v2cov_server_handlers8.py | 2 +- cloud/tests/test_v2cov_transplant.py | 1 - cloud/tests/test_v2cov_wait_ops.py | 14 ++++++++------ cloud/tests/test_v2cov_worker_deliver.py | 7 +++---- 26 files changed, 51 insertions(+), 80 deletions(-) diff --git a/cloud/tests/test_attempt_hook.py b/cloud/tests/test_attempt_hook.py index 4aea02e..060e7d8 100644 --- a/cloud/tests/test_attempt_hook.py +++ b/cloud/tests/test_attempt_hook.py @@ -51,7 +51,6 @@ try: PG_MARKER_DDL, classify_dispatch, consume_platform_marker, - ensure_marker_table, mark_platform_rerun, ) from cloud.attempt_ledger import ( @@ -72,7 +71,6 @@ except ImportError: PG_MARKER_DDL, classify_dispatch, consume_platform_marker, - ensure_marker_table, mark_platform_rerun, ) from cloud.attempt_ledger import ( diff --git a/cloud/tests/test_audit_loop_driver.py b/cloud/tests/test_audit_loop_driver.py index 98e78d0..29fd958 100644 --- a/cloud/tests/test_audit_loop_driver.py +++ b/cloud/tests/test_audit_loop_driver.py @@ -22,10 +22,7 @@ try: from cloud.audit_loop_driver import ( ACTION_KINDS, LEDGER_EVENT_TYPES, - Action, - LoopState, apply_correction, - build_ledger_event, confirm_rebuild, decide_audit, emit, @@ -38,10 +35,7 @@ except ImportError: from cloud.audit_loop_driver import ( ACTION_KINDS, LEDGER_EVENT_TYPES, - Action, - LoopState, apply_correction, - build_ledger_event, confirm_rebuild, decide_audit, emit, diff --git a/cloud/tests/test_audit_pushback.py b/cloud/tests/test_audit_pushback.py index d665ddf..1f92997 100644 --- a/cloud/tests/test_audit_pushback.py +++ b/cloud/tests/test_audit_pushback.py @@ -30,7 +30,6 @@ try: check_g6_guard, check_rebuild_first_gate, classify_root_cause, - collect_failed_checks, confirm_acceptance_rebuild, decide_pushback, deviation_is_blocking, @@ -64,7 +63,6 @@ except ImportError: check_g6_guard, check_rebuild_first_gate, classify_root_cause, - collect_failed_checks, confirm_acceptance_rebuild, decide_pushback, deviation_is_blocking, diff --git a/cloud/tests/test_cost_quota.py b/cloud/tests/test_cost_quota.py index bf693ff..57afa8b 100644 --- a/cloud/tests/test_cost_quota.py +++ b/cloud/tests/test_cost_quota.py @@ -9,7 +9,6 @@ _quota_exceeded（假 runner，不 dispatch），服务端点走本地 import http.client import json -import logging import os import sqlite3 import sys diff --git a/cloud/tests/test_coverage85_server.py b/cloud/tests/test_coverage85_server.py index 1325998..2d747fd 100644 --- a/cloud/tests/test_coverage85_server.py +++ b/cloud/tests/test_coverage85_server.py @@ -16,7 +16,6 @@ from decimal import Decimal from pathlib import Path try: - from cloud import server as _srv from cloud.server import ( DbRateLimiter, RateLimiter, @@ -77,7 +76,6 @@ try: ) except ImportError: # discover -s cloud/tests 时把项目根目录补进 sys.path sys.path.insert(0, str(Path(__file__).resolve().parents[2])) - from cloud import server as _srv from cloud.server import ( DbRateLimiter, RateLimiter, @@ -264,7 +262,6 @@ class PathHelpersTestCase(unittest.TestCase): self.assertIsNone(path) self.assertEqual(err[0], 409) # 异机 worktree 409。 - import socket path, err = _task_worktree_for_files( _StubServer(tenants_root="/tmp/t"), {"id": "t1", "worktree_host": "definitely-not-this-host-xyz"}) @@ -421,7 +418,7 @@ class TraceReadTestCase(unittest.TestCase): def test_build_agent_chain(self): # 主任务 + 模型子代理 + 委派子任务（done）三路。 - parent = self._write("task1.jsonl", [ + self._write("task1.jsonl", [ json.dumps({"id": "c1", "thread": "main-th", "kind": "message", "text": "hi", "ts": 10}), json.dumps({"id": "c2", "thread": "sub-th", "kind": "message", diff --git a/cloud/tests/test_coverage85_worker.py b/cloud/tests/test_coverage85_worker.py index 921c09b..e0a5d03 100644 --- a/cloud/tests/test_coverage85_worker.py +++ b/cloud/tests/test_coverage85_worker.py @@ -11,7 +11,6 @@ import sqlite3 import subprocess import sys import tempfile -import time import unittest from pathlib import Path @@ -506,7 +505,8 @@ class WorkerDbTestCase(unittest.TestCase): fake2 = Worker(self.db_path, "/fake/host.py", env={"XCM_API_KEY": "x"}, - repos_runner=lambda cmd, timeout=None: (_ for _ in ()).throw(TypeError("one-arg only")) if False else two_arg(cmd, timeout)) + repos_runner=(lambda cmd, timeout=None: (_ for _ in ()).throw(TypeError("one-arg only")) + if False else two_arg(cmd, timeout))) # 上面 fake2 的 runner 本身接受两参，直接验证两参路径。 self.assertEqual(fake2._run_git(["git"]), ("two", None)) diff --git a/cloud/tests/test_full_auto.py b/cloud/tests/test_full_auto.py index eb48db0..276549f 100644 --- a/cloud/tests/test_full_auto.py +++ b/cloud/tests/test_full_auto.py @@ -13,7 +13,6 @@ import tempfile import unittest from pathlib import Path -from cloud import full_auto from cloud.full_auto import ( FullAutoDenied, FullAutoError, diff --git a/cloud/tests/test_longfunc_remaining.py b/cloud/tests/test_longfunc_remaining.py index babaf68..e47d1be 100644 --- a/cloud/tests/test_longfunc_remaining.py +++ b/cloud/tests/test_longfunc_remaining.py @@ -13,7 +13,6 @@ 套件覆盖，本文件不重复测路由，只测抽出子块本身。 """ -import os import sys import unittest from pathlib import Path diff --git a/cloud/tests/test_tamper_ledger.py b/cloud/tests/test_tamper_ledger.py index 70ba395..73a7352 100644 --- a/cloud/tests/test_tamper_ledger.py +++ b/cloud/tests/test_tamper_ledger.py @@ -20,8 +20,7 @@ try: from cloud.cost import CostStore, dual_column_view, price_usd_micros from cloud.ledger import ( GENESIS_HASH, LedgerStore, append_pushback_round, - audit_timeline, export_chain, list_pushback_rounds, - module_failure_counts, verify_chain, verify_export) + list_pushback_rounds, verify_export) from cloud.server import create_server, init_db except ImportError: # discover -s cloud/tests 时把项目根目录补进 sys.path sys.path.insert(0, str(Path(__file__).resolve().parents[2])) @@ -29,8 +28,8 @@ except ImportError: # discover -s cloud/tests 时把项目根目录补进 sys.p from cloud.cost import CostStore, dual_column_view, price_usd_micros from cloud.ledger import ( GENESIS_HASH, LedgerStore, append_pushback_round, - audit_timeline, export_chain, list_pushback_rounds, - module_failure_counts, verify_chain, verify_export) + list_pushback_rounds, + verify_export) from cloud.server import create_server, init_db @@ -442,7 +441,7 @@ class TestTightenedCaliber(unittest.TestCase): contract_refrozen=True) def test_meta_review_correction_changes_effective_count(self): - first = self._verdict("fail") + self._verdict("fail") self._verdict("fail") third = self._verdict("fail") self.assertEqual( diff --git a/cloud/tests/test_v2cov_gaps_a.py b/cloud/tests/test_v2cov_gaps_a.py index 8b794f3..d6316d2 100644 --- a/cloud/tests/test_v2cov_gaps_a.py +++ b/cloud/tests/test_v2cov_gaps_a.py @@ -31,26 +31,22 @@ from unittest import mock REPO_ROOT = Path(__file__).resolve().parents[2] sys.path.insert(0, str(REPO_ROOT)) -import cloud.server as server_mod -from cloud import evidence_binding -from cloud import gate_verification -from cloud import ledger_onboarding -from cloud import ledger_outbox -from cloud.evidence_binding import ( +import cloud.server as server_mod # noqa: E402 +from cloud.evidence_binding import ( # noqa: E402 EvidenceNonceStore, bind_evidence, binding_presence, validate_bound_evidence, ) -from cloud.gate_verification import verify_gate_evidence -from cloud.ledger_onboarding import _table_columns, verify_ledger_ready -from cloud.ledger_outbox import ( +from cloud.gate_verification import verify_gate_evidence # noqa: E402 +from cloud.ledger_onboarding import _table_columns, verify_ledger_ready # noqa: E402 +from cloud.ledger_outbox import ( # noqa: E402 append_failure, outbox_path_for, read_failures, replay_failures, ) -from cloud.server import CloudControlPlaneHandler, init_db +from cloud.server import CloudControlPlaneHandler, init_db # noqa: E402 def _handler(db_path): diff --git a/cloud/tests/test_v2cov_gaps_b1.py b/cloud/tests/test_v2cov_gaps_b1.py index 3a8419e..fc2f287 100644 --- a/cloud/tests/test_v2cov_gaps_b1.py +++ b/cloud/tests/test_v2cov_gaps_b1.py @@ -27,8 +27,8 @@ from unittest import mock REPO_ROOT = Path(__file__).resolve().parents[2] sys.path.insert(0, str(REPO_ROOT)) -from cloud.server import init_db -from cloud.worker import Worker, _code_signature +from cloud.server import init_db # noqa: E402 +from cloud.worker import Worker, _code_signature # noqa: E402 FAKE_ENV = {"XCM_API_KEY": "test-placeholder"} @@ -155,7 +155,6 @@ class StepAndCheckpointTestCase(_Base): def test_checkpoint_mirror_loop_exception_swallowed(self): w = _worker(self.db_path) - calls = [] w._mirror_checkpoint_once = lambda task: (_ for _ in ()).throw( RuntimeError("mirror down")) class _Stop: diff --git a/cloud/tests/test_v2cov_gaps_d1.py b/cloud/tests/test_v2cov_gaps_d1.py index 9bd6e24..ac6d2b0 100644 --- a/cloud/tests/test_v2cov_gaps_d1.py +++ b/cloud/tests/test_v2cov_gaps_d1.py @@ -23,8 +23,8 @@ from unittest import mock REPO_ROOT = Path(__file__).resolve().parents[2] sys.path.insert(0, str(REPO_ROOT)) -from cloud.server import init_db -from cloud.worker import Worker +from cloud.server import init_db # noqa: E402 +from cloud.worker import Worker # noqa: E402 FAKE_ENV = {"XCM_API_KEY": "test-placeholder"} diff --git a/cloud/tests/test_v2cov_gaps_d2.py b/cloud/tests/test_v2cov_gaps_d2.py index bf4f1bb..d9984ac 100644 --- a/cloud/tests/test_v2cov_gaps_d2.py +++ b/cloud/tests/test_v2cov_gaps_d2.py @@ -25,8 +25,8 @@ from unittest import mock REPO_ROOT = Path(__file__).resolve().parents[2] sys.path.insert(0, str(REPO_ROOT)) -from cloud.server import init_db -from cloud.worker import Worker +from cloud.server import init_db # noqa: E402 +from cloud.worker import Worker # noqa: E402 FAKE_ENV = {"XCM_API_KEY": "test-placeholder"} diff --git a/cloud/tests/test_v2cov_gaps_d4.py b/cloud/tests/test_v2cov_gaps_d4.py index 6da3672..0fc10d6 100644 --- a/cloud/tests/test_v2cov_gaps_d4.py +++ b/cloud/tests/test_v2cov_gaps_d4.py @@ -18,8 +18,8 @@ from unittest import mock REPO_ROOT = Path(__file__).resolve().parents[2] sys.path.insert(0, str(REPO_ROOT)) -from cloud import server as server_mod -from cloud.ledger_outbox import replay_failures +from cloud import server as server_mod # noqa: E402 +from cloud.ledger_outbox import replay_failures # noqa: E402 class DispatchSafeTestCase(unittest.TestCase): diff --git a/cloud/tests/test_v2cov_marker_pure.py b/cloud/tests/test_v2cov_marker_pure.py index 1a62d8b..4e15cdd 100644 --- a/cloud/tests/test_v2cov_marker_pure.py +++ b/cloud/tests/test_v2cov_marker_pure.py @@ -13,7 +13,7 @@ from unittest import mock REPO_ROOT = Path(__file__).resolve().parents[2] sys.path.insert(0, str(REPO_ROOT)) -from cloud.marker_tools import ( +from cloud.marker_tools import ( # noqa: E402 _as_int, _heartbeat_age_text, _model_from_match, diff --git a/cloud/tests/test_v2cov_server_handlers.py b/cloud/tests/test_v2cov_server_handlers.py index b0d66c4..75c55cc 100644 --- a/cloud/tests/test_v2cov_server_handlers.py +++ b/cloud/tests/test_v2cov_server_handlers.py @@ -16,12 +16,10 @@ and emit-failure logic under test stays real). """ import io -import json import os import sqlite3 import sys import tempfile -import time import unittest import urllib.error from pathlib import Path @@ -31,9 +29,9 @@ from unittest import mock REPO_ROOT = Path(__file__).resolve().parents[2] sys.path.insert(0, str(REPO_ROOT)) -import cloud.server as server_mod -from cloud.handler_fullauto import FullAutoError, _full_auto_branch_protection_ok, _full_auto_github_request -from cloud.server import ( +import cloud.server as server_mod # noqa: E402 +from cloud.handler_fullauto import FullAutoError, _full_auto_branch_protection_ok, _full_auto_github_request # noqa: E402 +from cloud.server import ( # noqa: E402 CloudControlPlaneHandler, init_db, ) diff --git a/cloud/tests/test_v2cov_server_handlers2.py b/cloud/tests/test_v2cov_server_handlers2.py index 5014c4a..77b7f2a 100644 --- a/cloud/tests/test_v2cov_server_handlers2.py +++ b/cloud/tests/test_v2cov_server_handlers2.py @@ -19,7 +19,6 @@ logic -- validation, permission checks via the real AuthStore, quota gates, driver result shaping -- runs for real. """ -import json import os import sqlite3 import sys @@ -33,9 +32,9 @@ from unittest import mock REPO_ROOT = Path(__file__).resolve().parents[2] sys.path.insert(0, str(REPO_ROOT)) -import cloud.server as server_mod -from cloud.server import CloudControlPlaneHandler, _auth_store, init_db -from cloud.sub2api import Sub2apiError as _Sub2apiError +import cloud.server as server_mod # noqa: E402 +from cloud.server import CloudControlPlaneHandler, _auth_store, init_db # noqa: E402 +from cloud.sub2api import Sub2apiError as _Sub2apiError # noqa: E402 def _handler(db_path, upload_dir=None): diff --git a/cloud/tests/test_v2cov_server_handlers3.py b/cloud/tests/test_v2cov_server_handlers3.py index f244afc..b342e61 100644 --- a/cloud/tests/test_v2cov_server_handlers3.py +++ b/cloud/tests/test_v2cov_server_handlers3.py @@ -29,13 +29,12 @@ from unittest import mock REPO_ROOT = Path(__file__).resolve().parents[2] sys.path.insert(0, str(REPO_ROOT)) -import cloud.server as server_mod -from cloud.server import ( +from cloud.server import ( # noqa: E402 CloudControlPlaneHandler, _auth_store, init_db, ) -from cloud.sub2api import Sub2apiError as _Sub2apiError +from cloud.sub2api import Sub2apiError as _Sub2apiError # noqa: E402 def _handler(db_path, upload_dir=None): @@ -459,7 +458,6 @@ class TodosAutomationLoopTestCase(_Base): self._project() self._task() from cloud.audit_loop_wiring import ( - ensure_loop_state_table, save_loop_state, ) from cloud.audit_loop_driver import LoopState diff --git a/cloud/tests/test_v2cov_server_handlers4.py b/cloud/tests/test_v2cov_server_handlers4.py index e5a37cd..a03e554 100644 --- a/cloud/tests/test_v2cov_server_handlers4.py +++ b/cloud/tests/test_v2cov_server_handlers4.py @@ -20,7 +20,7 @@ from unittest import mock REPO_ROOT = Path(__file__).resolve().parents[2] sys.path.insert(0, str(REPO_ROOT)) -from cloud.server import ( +from cloud.server import ( # noqa: E402 CloudControlPlaneHandler, _auth_store, init_db, diff --git a/cloud/tests/test_v2cov_server_handlers5.py b/cloud/tests/test_v2cov_server_handlers5.py index 47dbbee..3e4812e 100644 --- a/cloud/tests/test_v2cov_server_handlers5.py +++ b/cloud/tests/test_v2cov_server_handlers5.py @@ -8,7 +8,6 @@ stubbed only to drive the handler's own error mapping. """ import os -import socket import sqlite3 import sys import tempfile @@ -21,12 +20,11 @@ from unittest import mock REPO_ROOT = Path(__file__).resolve().parents[2] sys.path.insert(0, str(REPO_ROOT)) -from cloud.server import ( +from cloud.server import ( # noqa: E402 CloudControlPlaneHandler, _auth_store, init_db, ) -from cloud.sub2api import Sub2apiError as _Sub2apiError def _handler(db_path, upload_dir=None, tenants_root=None): diff --git a/cloud/tests/test_v2cov_server_handlers6.py b/cloud/tests/test_v2cov_server_handlers6.py index a9bf529..2c2242b 100644 --- a/cloud/tests/test_v2cov_server_handlers6.py +++ b/cloud/tests/test_v2cov_server_handlers6.py @@ -23,14 +23,14 @@ from unittest import mock REPO_ROOT = Path(__file__).resolve().parents[2] sys.path.insert(0, str(REPO_ROOT)) -from cloud.server import ( +from cloud.server import ( # noqa: E402 CloudControlPlaneHandler, _auth_store, init_db, ) -from cloud.full_auto import FullAutoError -from cloud.oauth import BindError -from cloud.wait_ops import create_handoff as _handoff_create +from cloud.full_auto import FullAutoError # noqa: E402 +from cloud.oauth import BindError # noqa: E402 +from cloud.wait_ops import create_handoff as _handoff_create # noqa: E402 def _handler(db_path, upload_dir=None, tenants_root=None): diff --git a/cloud/tests/test_v2cov_server_handlers7.py b/cloud/tests/test_v2cov_server_handlers7.py index 5fe0078..1f14ea8 100644 --- a/cloud/tests/test_v2cov_server_handlers7.py +++ b/cloud/tests/test_v2cov_server_handlers7.py @@ -22,8 +22,8 @@ from unittest import mock REPO_ROOT = Path(__file__).resolve().parents[2] sys.path.insert(0, str(REPO_ROOT)) -from cloud.handler_fullauto import _full_auto_installation_verified, _full_auto_parse_plan_params -from cloud.server import ( +from cloud.handler_fullauto import _full_auto_installation_verified, _full_auto_parse_plan_params # noqa: E402 +from cloud.server import ( # noqa: E402 CloudControlPlaneHandler, RateLimiter, _apply_default_quota, @@ -47,7 +47,7 @@ from cloud.server import ( sweep_rate_limit_hits, DbRateLimiter, ) -from cloud.server import _auth_store as _auth_store_cm +from cloud.server import _auth_store as _auth_store_cm # noqa: E402 def _handler(db_path, upload_dir=None, tenants_root=None): diff --git a/cloud/tests/test_v2cov_server_handlers8.py b/cloud/tests/test_v2cov_server_handlers8.py index 30a873a..f46c0af 100644 --- a/cloud/tests/test_v2cov_server_handlers8.py +++ b/cloud/tests/test_v2cov_server_handlers8.py @@ -25,7 +25,7 @@ from unittest import mock REPO_ROOT = Path(__file__).resolve().parents[2] sys.path.insert(0, str(REPO_ROOT)) -from cloud.server import ( +from cloud.server import ( # noqa: E402 CloudControlPlaneHandler, init_db, ) diff --git a/cloud/tests/test_v2cov_transplant.py b/cloud/tests/test_v2cov_transplant.py index 923a9de..d73522b 100644 --- a/cloud/tests/test_v2cov_transplant.py +++ b/cloud/tests/test_v2cov_transplant.py @@ -15,7 +15,6 @@ plus small variants that trip each loud-failure branch. import contextlib import importlib.util import io -import sys import tempfile import unittest from pathlib import Path diff --git a/cloud/tests/test_v2cov_wait_ops.py b/cloud/tests/test_v2cov_wait_ops.py index 400d932..51fa0ab 100644 --- a/cloud/tests/test_v2cov_wait_ops.py +++ b/cloud/tests/test_v2cov_wait_ops.py @@ -15,7 +15,7 @@ from unittest import mock REPO_ROOT = Path(__file__).resolve().parents[2] sys.path.insert(0, str(REPO_ROOT)) -from cloud.wait_ops import ( +from cloud.wait_ops import ( # noqa: E402 _normalize_json_checks, _row_dict, build_pr_diagnostics, @@ -189,10 +189,11 @@ class WaitCoresTestCase(unittest.TestCase): self.assertEqual((task_id, kind), ("t1", "needs_continue")) def test_poll_first_bad_timeout_immediate(self): - fetch = lambda: {"t1": {"status": "completed", - "pending_approvals": 0, - "pending_input": 0, - "pending_followups": 0}} + def fetch(): + return {"t1": {"status": "completed", + "pending_approvals": 0, + "pending_input": 0, + "pending_followups": 0}} changed, summaries, waited, timed_out = poll_for_first_change( fetch, ["t1"], timeout_seconds="bad") self.assertEqual(changed["kind"], "terminal") @@ -204,7 +205,8 @@ class WaitCoresTestCase(unittest.TestCase): {"t1": {"status": "completed", "pending_approvals": 0, "pending_input": 0, "pending_followups": 0}}] it = iter(seq) - fetch = lambda: next(it, seq[-1]) + def fetch(): + return next(it, seq[-1]) changed, summaries, waited, timed_out = poll_for_first_change( fetch, ["t1"], timeout_seconds=5, poll_seconds=0.01) self.assertEqual(changed["kind"], "terminal") diff --git a/cloud/tests/test_v2cov_worker_deliver.py b/cloud/tests/test_v2cov_worker_deliver.py index 95100c2..8d07880 100644 --- a/cloud/tests/test_v2cov_worker_deliver.py +++ b/cloud/tests/test_v2cov_worker_deliver.py @@ -36,9 +36,9 @@ from unittest import mock REPO_ROOT = Path(__file__).resolve().parents[2] sys.path.insert(0, str(REPO_ROOT)) -from cloud.server import init_db -from cloud.todos import create_todo as _create_todo -from cloud.worker import Worker +from cloud.server import init_db # noqa: E402 +from cloud.todos import create_todo as _create_todo # noqa: E402 +from cloud.worker import Worker # noqa: E402 FAKE_ENV = {"XCM_API_KEY": "test-placeholder"} @@ -283,7 +283,6 @@ class ControlFallbackTestCase(DeliverBase): def test_retry_not_done_when_rowcount_zero(self): self._insert("E1", status="failed", parent="PM") worker = self._worker() - real_connect = sqlite3.connect class _CursorProxy: def __init__(self, real):