Determines if we should auto-register the original Python instead of downloading.

Decide if we should proactively use worker mode for this package.

Notify daemon of completion + remove op marker. Always called from finally.

Touch op marker + notify daemon. Returns (daemon_client, op_marker).

Final-depth cleanup: restore any remaining cloaks using safe ops.

Starts the raw Python process. Sits waiting for JSON spec.

Stabilize TensorFlow's C++ extensions (only if TF is loaded).

Ensure numpy array is in a stable state (only if numpy is available).

(FIXED) The background refresh now ALSO uses the robust `pip`-based check to prevent it from ever polluting the cache with incompatib

Start daemon on Windows using subprocess.

Stable-main fast path: instead of install→create_bubble→restore, we: 1. Rename current pkg dirs to *.___stash___ so uv skips uninstal

Store original state with contamination filtering to prevent cross-version issues.

Stores metadata using hash of resolved dist._path

Returns (outcome, result_tuple, installed, removed).

Restores a cloaked package in the main environment so it can be used.

Updates the default python/python3 to point to the venv Python.

Validate that a package can actually be imported after activation. Special handling for PyTorch which cannot be reloaded.

Basic file existence checks (your original logic, kept for completeness)

Verify all packages in a group together IN A STERILE SUBPROCESS. CRITICAL FIX V2: Now includes dependency bubbles so keras can impor

Off hot-path: attempt a quick import of pkg_name and detect the known .so-already-mapped / partial-init / circular-import failures.

SMART VERSION: Uses the One True Verifier to check importability.

ENHANCED VERSION: Now uses the same robust import verification as the main installer. This catches issues like missing flask_login.co

Ask the actual Python executable what version it is...

Lightweight startup check: if the registry has interpreters but their versioned entry-point symlinks are missing or broken, recreate

Return the versioned command name: 3.9 -> 8pkg39, 3.10 -> 8pkg310, etc.

Fixed version that works on Windows and Unix Wait for daemon to be ready to accept connections

Write one JSON line to the real stdout pipe, bypassing StreamRedirector.

Read one JSON line from worker stdin (the daemon reply channel). The daemon writes to worker.process.stdin (also text mode) after receiving t

Spinlock using LOCK CMPXCHG. Protocol: We only lock if Version is EVEN. Action: CAS(Current, Current + 1). Returns: T

Activate the omnipkg environment

Automatically patch Flask code to use an available port.

basename without modifying input */

Block the calling thread until the dirty flag is cleared. Called by the UV worker BEFORE invoking FFI. Returns immediately if

Check if package has known compatibility issues Args: package: Package name python_version: e.g. "3.11"

Check if a specific package version is installed in the target python environment by running an isolated subprocess.

Check if current Python version can run the old flask-login version.

Check if a Python version is available via ConfigManager.

🔒 ENHANCED VALIDATOR v4 - Non-Interactive Friendly Security features: - Whitelist-based command validation - Argument pattern matchi

Skips cleanup to leave packages installed for faster re-testing.

Removes any temporary backup files.

Remove orphaned shared memory blocks from /dev/shm/.

Remove all expired entries from cache.

Configure idle worker pools.

Client function to connect to daemon (works on both platforms)

Creates the Flask application with telemetry support.

Creates a complete, isolated bubble for a package, including all its dependencies. For editable/dev installs, copies directly from th

--- [REWRITTEN] --- Creates an isolated bubble by using the new unified, safe installation workflow.

Creates a temporary Python script that loads config from a file. This is the PROPER way to pass config to subprocess scripts - no string esc

Create a wrapper script for a CLI tool that auto-heals conflicts

Run cProfile INSIDE the worker process for each transport path. All four probes use execute_shm so the result dict comes back intact. Th

Clean up the environment

Detect version conflicts for a CLI tool and its dependencies

Check if UV output contains dependency resolution failure

Find all hallucinated import lines. Returns: List of (line, module_name, is_obvious) tuples

Detect and add all loader hint specs to healing plan

Detect the omnipkg venv root from env or config.

Find all CLI tools installed in the current environment

Diagnoses and repairs a corrupted environment. Phase 0: heal broken metadata (missing METADATA files in dist-info dirs) Phase

Emit a UTF-8 codepoint into a growable buffer. */

Ensures the worker daemon is up and running.

Start daemon if not running, then wait until it has spawned idle workers for ALL of the given interpreter paths. Must be called AFTER all pyt

Ensures JAX and JAXlib are always paired with matching versions. Strategy: 1. If user specified jax version -> use it as master, ensure j