diff --git a/decnet/bus/factory.py b/decnet/bus/factory.py index f7a935ac..6743da1c 100644 --- a/decnet/bus/factory.py +++ b/decnet/bus/factory.py @@ -76,7 +76,7 @@ def _maybe_wrap_telemetry(bus: BaseBus) -> BaseBus: up at all we no-op. """ try: - from decnet.telemetry import wrap_repository # type: ignore[attr-defined] + from decnet.telemetry import wrap_repository except ImportError: return bus try: diff --git a/decnet/canary/dns_server.py b/decnet/canary/dns_server.py index 65cc6f60..b8d25756 100644 --- a/decnet/canary/dns_server.py +++ b/decnet/canary/dns_server.py @@ -169,10 +169,10 @@ class CanaryDNSProtocol(asyncio.DatagramProtocol): self._answer_ip = answer_ip self._transport: Optional[asyncio.DatagramTransport] = None - def connection_made(self, transport) -> None: # type: ignore[override] - self._transport = transport # type: ignore[assignment] + def connection_made(self, transport) -> None: + self._transport = transport - def datagram_received( # type: ignore[override] + def datagram_received( self, data: bytes, addr: Tuple[str, int], ) -> None: try: diff --git a/decnet/canary/generators/honeydoc_pdf.py b/decnet/canary/generators/honeydoc_pdf.py index 400271ff..681e134e 100644 --- a/decnet/canary/generators/honeydoc_pdf.py +++ b/decnet/canary/generators/honeydoc_pdf.py @@ -43,7 +43,7 @@ class HoneydocPdfGenerator(CanaryGenerator): def generate(self, ctx: CanaryContext) -> CanaryArtifact: try: - from pikepdf import Pdf, Name, Dictionary, String # type: ignore[import-not-found] + from pikepdf import Pdf, Name, Dictionary, String except ImportError as e: raise InstrumenterRejectedError( "honeydoc_pdf requires pikepdf; install it (`pip install " diff --git a/decnet/canary/instrumenters/image.py b/decnet/canary/instrumenters/image.py index 69e31ff4..99052a83 100644 --- a/decnet/canary/instrumenters/image.py +++ b/decnet/canary/instrumenters/image.py @@ -32,7 +32,7 @@ class ImageInstrumenter(CanaryInstrumenter): self, blob: bytes, ctx: CanaryContext, *, target_path: str, ) -> CanaryArtifact: try: - from PIL import Image, PngImagePlugin # type: ignore[import-not-found] + from PIL import Image, PngImagePlugin except ImportError as e: raise InstrumenterRejectedError( "image instrumenter requires Pillow; install it (`pip " diff --git a/decnet/canary/instrumenters/pdf.py b/decnet/canary/instrumenters/pdf.py index 516b6999..e868f8b0 100644 --- a/decnet/canary/instrumenters/pdf.py +++ b/decnet/canary/instrumenters/pdf.py @@ -34,7 +34,7 @@ class PdfInstrumenter(CanaryInstrumenter): self, blob: bytes, ctx: CanaryContext, *, target_path: str, ) -> CanaryArtifact: try: - import pikepdf # type: ignore[import-not-found] + import pikepdf except ImportError as e: raise InstrumenterRejectedError( "PDF instrumenter requires pikepdf; install it (`pip " diff --git a/decnet/canary/worker.py b/decnet/canary/worker.py index 280a717b..8218136d 100644 --- a/decnet/canary/worker.py +++ b/decnet/canary/worker.py @@ -214,7 +214,7 @@ async def _start_dns_server( local_addr=(_dns_bind(), _dns_port()), ) log.info("canary.dns listening zone=%s port=%d", zone, _dns_port()) - return transport # type: ignore[return-value] + return transport # ---------------------------- entry point -------------------------------- diff --git a/decnet/collector/worker.py b/decnet/collector/worker.py index da548d29..0d8717b6 100644 --- a/decnet/collector/worker.py +++ b/decnet/collector/worker.py @@ -346,7 +346,7 @@ def _stream_container( publish_fn: CollectorPublishFn | None = None, ) -> None: """Stream logs from one container and append to the host log files.""" - import docker # type: ignore[import] + import docker lf: Optional[Any] = None jf: Optional[Any] = None @@ -450,7 +450,7 @@ async def log_collector_worker(log_file: str) -> None: Watches Docker events to pick up containers started after initial scan. """ - import docker # type: ignore[import] + import docker log_path = Path(log_file) json_path = log_path.with_suffix(".json") diff --git a/decnet/topology/validate.py b/decnet/topology/validate.py index 338e55e9..bc241659 100644 --- a/decnet/topology/validate.py +++ b/decnet/topology/validate.py @@ -305,7 +305,7 @@ def check_no_host_port_collision(h: dict[str, Any]) -> list[ValidationIssue]: return [] try: - import psutil # type: ignore + import psutil bound = { c.laddr.port for c in psutil.net_connections(kind="inet") diff --git a/decnet/vectorstore/sqlite_vec.py b/decnet/vectorstore/sqlite_vec.py index b38c414d..46b46ca1 100644 --- a/decnet/vectorstore/sqlite_vec.py +++ b/decnet/vectorstore/sqlite_vec.py @@ -45,7 +45,7 @@ class SqliteVecUnavailable(RuntimeError): def _load_sqlite_vec(conn: sqlite3.Connection) -> None: try: - import sqlite_vec # type: ignore[import-untyped] + import sqlite_vec except ImportError as e: raise SqliteVecUnavailable("sqlite_vec package not installed") from e try: diff --git a/decnet/web/worker_registry.py b/decnet/web/worker_registry.py index 2db56d5d..c36e076a 100644 --- a/decnet/web/worker_registry.py +++ b/decnet/web/worker_registry.py @@ -99,7 +99,7 @@ class WorkerRegistry: payload.pop("ts", None) out.append(WorkerStatus( name=name, - status=status, # type: ignore[arg-type] + status=status, last_heartbeat_ts=ts, seconds_since=seconds_since, extra=payload,