Generates a unique, deterministic Redis key for a specific package instance.

Gets all instance data from KB, organized by package name and version, but ONLY for instances indexed by the specified Python version

Return the set of Python version strings currently registered in the omnipkg interpreter registry (e.g. {'3.9', '3.10', '3.11'}). Used b

Get a worker from the pool, or create one if it doesn't exist. This is the KEY to performance - workers stay alive between activatio

Get packages in bubbles, but only those created for the current Python version.

Disk-cached site-packages lookup - only used as last resort fallback.

Fetches the wheel URL for a specific package version from PyPI.

Iterates through every module in the package. If a module fails to import, it scans ALL other bubbles of this package to find

Handle client request with timeout protection.

Handles the 'Quantum Healing' process when a package is incompatible with the current Python version. It attempts to switch to a comp

Called when Redis is configured but unavailable. Updates config to prevent repeated connection attempts and notifies the user.

Graceful shutdown with timeout. Windows + Linux compatible.

NUCLEAR HEALING with file locking to prevent race conditions

CRITICAL FIX: Actually test worker responsiveness.

(QUIET VERSION) Scans for and removes ALL ghost .dist-info directories, only printing output if it finds and deletes something.

Lazy accessor for the _ translation function.

Install a bubble directly (called by daemon during worker creation). Returns True if successful.

Spawns a fresh, clean Python process to check if the bubble is actually importable. If this returns True, the bubble is fine, but our

Checks if a given distribution is compatible with the specified python_version context.

Check if this dist-info belongs to a sub-component that shouldn't be treated independently.

Return True if `version` *could* be a real CPython release, i.e. the major is 3 and the minor is in a sensible range (0-99). This gates

Load __init__.py with _native patched to the mock.

Proxy for compatibility during migration.

Load path registry (placeholder for your path management).

Pre-spawns Python processes for specific executables so they are ready instantly.

Background thread that enforces two levels of memory policy: 1. Per-worker cap (``max_memory_mb`` set at call time): A sp

Stabilized numpy to tensor conversion (with graceful fallback).

Runs at process exit to ensure clean termination of CUDA/C++ components.

Worker function for parallel discovery with AUTO-HEALING. If metadata is corrupt, attempts emergency repair before giving up.

Safely checks the config file for a boolean flag for the current environment without fully loading the ConfigManager. Returns False i

Full network-based resolution when cache miss occurs. This is your existing logic, extracted for clarity.

(V5 - BOOTSTRAP AWARE) Runs a security check on ALL packages. Detects if it's running during initial KB build and uses a safe fallbac

(CORRECTED) Scans all existing package entries and adds the 'install_type' and 'owner_package' fields based on their path.

Before uv destroys old versions, hardlink their files into bubble dirs. Returns dict of {pkg_name: bubble_path} for packages successf

(V3.1 - Vendored Fix) Processes a single distribution, now correctly including vendored packages instead of skipping them.

Enhanced version that includes original interpreters in the scan.

Register bubble location and summary statistics in a single batch operation.

Register bubble paths in Redis for dedup across bubbles and main env.

Register a file in the registry.

Register a bubbled package in the knowledge base. This integrates with your existing knowledge base system.

Surgically repairs a bubble's manifest file if its `python_version` does not match the Python context of its current location.

Directly modifies the config file on disk to reset the setup flag.

(UPGRADED) Takes a list of packages and ensures every entry has an explicit '==' version. It now intelligently dispatches to the corr

(V6 - AUTO INDEX DETECTION) Automatically detects special index URLs for packages like PyTorch CUDA variants, then validates with pip

Restores from a specific pre-install snapshot

Restores the main environment to the exact state of a given snapshot.

Stream pip output live so the user can see progress instead of a silent hang.

(V2 - CONTEXT-AWARE FIX) Atomically updates the knowledge base by directly invoking the metadata gatherer in-process, now correctly p

FIXED: Properly isolates sys.path to ONLY use the staging directory.

Strategy 1: Check for vendored packages (SILENT except in verbose mode)

Strategy 2: Direct pattern matching (SILENT except in verbose mode)

Strategy 3: Nested directory search (SILENT except in verbose mode)

Strategy 4: Comprehensive fallback scan (SILENT except in verbose mode)

Strategy 5: Authoritative lookup via importlib.metadata, scoped to specific paths.

Strategy 6: Recursive Exact Match (Surgical Strike). Specifically looks for 'package-version.dist-info' anywhere in the tree.

Runs `uv install` for a list of packages.

Runs `uv pip uninstall` for a list of packages.

Resolve a path safely for omnipkg identity and path comparisons. Uses resolve() when possible, falls back to absolute() if resolution fails.

Looks for other installed versions of this package and tries to copy missing files from them. This is the 'Frankenstein' logic.

Send an arbitrary JSON message string to the daemon socket.

Performs the one-time setup for an environment that already has Python 3.11. This primarily involves symlinking and registering the i

DEPRECATED STUB — no longer used by determine_target_python(). Kept so any external callers don't break.

Return True if the mapped .so for this module still exists on disk.

Sorts packages for installation based on the chosen strategy. - 'latest-active': Sorts oldest to newest to ensure the last one instal