fix(windows): drive-letter worker refs, win32 mypy guards, client read timeout

- serve: a bare 'C:\path\worker.py' reference split at the drive-letter
  colon and tried to import module 'C'; only treat ':' as the
  module:Class separator when the head isn't a lone drive letter.
- Guard AF_UNIX (transactor), SIGKILL (crash fixture), and getpgrp
  (schema_reconcile db path) behind sys.platform for Windows mypy,
  with Windows-appropriate fallbacks.
- Client: httpx's 5s default read timeout is too aggressive for RPC
  calls that do real server-side work; use 60s read / 10s connect.
  (Fixes resumable-scan flakiness on slow Windows runners.)

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>

Author: rustyconover

vgi/_test_fixtures/schema_reconcile/worker.py

@@ -28,6 +28,7 @@
 import os
 import pickle
 import sqlite3
+import sys
 import threading
 from dataclasses import dataclass
 from typing import Any
@@ -185,6 +186,11 @@ def _db_path() -> str:
     # because ``uv run`` inserts an intermediate process per worker; PGID
     # propagates across fork/exec by default and stays stable for the
     # life of one test session.
+    if sys.platform == "win32":  # pragma: no cover - PGID is POSIX; PPID is the
+        # closest stable-per-session stand-in.
+        import tempfile
+
+        return os.path.join(tempfile.gettempdir(), f"vgi_schema_reconcile.{os.getppid()}.sqlite")
     return f"/tmp/vgi_schema_reconcile.{os.getpgrp()}.sqlite"
 
 

vgi/_test_fixtures/table_in_out.py

@@ -38,6 +38,7 @@
 
 import os
 import signal
+import sys
 import time
 from dataclasses import dataclass
 from typing import Annotated, Any
@@ -945,7 +946,10 @@ def process(
         batch: pa.RecordBatch,
         params: TableBufferingParams[SingleTableArguments],
     ) -> bytes:
-        os.kill(os.getpid(), signal.SIGKILL)
+        if sys.platform == "win32":  # pragma: no cover - hard-crash equivalent
+            os.kill(os.getpid(), signal.SIGABRT)
+        else:
+            os.kill(os.getpid(), signal.SIGKILL)
         return params.execution_id  # unreachable
 
 

vgi/client/client.py

@@ -71,8 +71,8 @@
 import logging
 import os
 import shlex
-import sys
 import subprocess
+import sys
 import threading
 from collections.abc import Callable, Generator, Iterator
 from contextlib import AbstractContextManager
@@ -616,6 +616,9 @@ def _get_or_create_httpx_client(self) -> Any:
             base_url=self._base_url or "",
             follow_redirects=True,
             headers=headers,
+            # httpx's 5s default read timeout is too aggressive for RPC
+            # calls that do real server-side work (scans, cold workers).
+            timeout=httpx.Timeout(60.0, connect=10.0),
         )
         self._httpx_client_owned = True
         return self._httpx_client

vgi/serve.py

@@ -83,7 +83,11 @@ def load_worker_class(reference: str) -> type[Worker]:
     module_ref: str = reference
 
     if ":" in reference:
-        module_ref, class_name = reference.rsplit(":", 1)
+        head, tail = reference.rsplit(":", 1)
+        # A lone Windows drive-letter colon ("C:\path\worker.py") is part
+        # of the path, not a module:Class separator.
+        if not (len(head) == 1 and head.isalpha() and tail[:1] in ("\\", "/")):
+            module_ref, class_name = head, tail
 
     # Load the module
     module = _load_module(module_ref)

vgi/transactor/client.py

@@ -25,6 +25,7 @@
 import logging
 import os
 import subprocess
+import sys
 import time
 from pathlib import Path
 from typing import Any
@@ -81,14 +82,17 @@ def _try_connect(self) -> bool:
         """Try to connect to an existing transactor socket."""
         import socket
 
+        if sys.platform == "win32":  # pragma: no cover - AF_UNIX transactor is POSIX-only
+            return False
+
         if not os.path.exists(self._socket_path):
             return False
 
         try:
             sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
             sock.connect(self._socket_path)
             self._transport = UnixTransport(sock)
-            self._connection = RpcConnection(TransactorProtocol, self._transport)  # type: ignore[type-abstract]
+            self._connection = RpcConnection(TransactorProtocol, self._transport)  # type: ignore[type-abstract, unused-ignore]
             self._proxy = self._connection.__enter__()
             logger.info("Connected to transactor: %s", self._socket_path)
             return True