steps

Author: epatey

src/inspect_scout/_concurrency/_mp_logging.py

@@ -18,6 +18,7 @@ def patch_inspect_log_handler(patch_fn: Callable[[logging.LogRecord], None]) ->
         patch_fn: A callable that receives a LogRecord and handles it (typically by
             queuing it for transmission to the parent process).
     """
+    # TODO: Disabled until we fix it
     # object.__setattr__(find_inspect_log_handler(), "emit", patch_fn)
 
 

src/inspect_scout/_concurrency/_mp_subprocess.py

@@ -8,9 +8,6 @@
 
 from __future__ import annotations
 
-# IMPORTANT: Import _mp_setup FIRST to configure sys.path before unpickling
-from . import _mp_setup  # noqa: F401
-
 import logging
 import time
 from threading import Condition
@@ -23,7 +20,12 @@
 
 from .._scanner.result import ResultReport
 from .._transcript.types import TranscriptInfo
-from . import _mp_common
+
+# IMPORTANT: Import _mp_setup FIRST to configure sys.path before unpickling
+from . import (
+    _mp_common,
+    _mp_setup,  # noqa: F401
+)
 from ._iterator import iterator_from_queue
 from ._mp_common import IPCContext, LoggingItem, run_sync_on_thread
 from ._mp_logging import patch_inspect_log_handler
@@ -73,7 +75,7 @@ def _wait_for_shutdown() -> None:
 def subprocess_main(
     worker_id: int,
     task_count: int,
-    ipc_context: IPCContext,
+    ctx: IPCContext,
 ) -> None:
     """Worker subprocess main function.
 
@@ -83,10 +85,8 @@ def subprocess_main(
     Args:
         worker_id: Unique identifier for this worker process
         task_count: Number of concurrent tasks for this worker process
-        ipc_context: Shared IPC context passed from parent process
+        ctx: Shared IPC context passed from parent process
     """
-    # Use IPC context passed as argument (for spawn compatibility)
-    ctx = ipc_context
 
     def _log_in_parent(record: logging.LogRecord) -> None:
         # Strip exc_info from record to avoid pickling traceback objects since it

test_env_inherit.py

@@ -1,4 +1,12 @@
-# Fork to Spawn Conversion - COMPLETED ✅
+# Fork to Spawn Conversion
+
+## Remaining Issues
+
+- [ ] Only works if cd into directory with scan job
+- [ ] Remaining Busted Items that relied on the fork approach
+  Likely all of these can be fixed by performing proper initialization code in `worker_main`
+  - [ ] Monkey patching logging 
+  - [ ] Shared concurrency model
 
 ## Final Solution