Proxies calls from Loader to the Daemon via Socket/SHM

Custom exception raised when a package EXISTS on PyPI but is incompatible with the current Python version. This exception carries the necessa

A persistent subprocess that acts as a specific package environment. Provides REAL-TIME output streaming.

A group of packages that must be tested together.

Heals AI-generated code that hallucinates placeholder imports.

A SQLite-based cache client that emulates Redis commands.

Result of a package verification test.

Protects critical Conda metadata files by creating temporary backups before a sensitive operation and restoring them if corruption is detecte

Sends a `patch_site_packages_cache` message to the daemon. The daemon forwards installed/removed lists to each UV worker which calls the

Tiny file-based invalidation signal for _dependency_cache. Every safe_cloak / safe_uncloak call touches this file. Daemon workers call i

Manages multiple Python interpreters within the same environment. Provides methods to switch between interpreters and run commands with speci

Manages package index URL detection for special variants like PyTorch CUDA builds. Supports both built-in rules and user-customizable configu

CUDA IPC memory handle structure.

Dual lock: holds the per-package lock AND the short scan-guard lock for the duration of a rename. The scan-guard is held only during the act

Manages an activated omnipkg environment

Raised when omnipkg detects that the current process memory is corrupted by a C++ state collision and cannot be recovered without a full rest

Handles filesystem events inside a site-packages directory. Only cares about .dist-info / .data directory creation/deletion and direct f

Single entry-point for the fs-watcher subsystem. Designed to be embedded inside WorkerPoolDaemon (runs in a daemon thread) OR as a stand

Raised when the lock could not be acquired in *timeout* seconds.

Detects UV dependency resolution failures.

A context aware object that will release the lock file when exiting.

Handles execution of both scripts and CLI commands with auto-healing

A stderr wrapper that filters out annoying warnings in real-time.

Manages Flask app lifecycle with graceful shutdown support.

Context passed to hook functions.

Available IPC transfer modes.

Monitors a process and kills it if it stays idle (low CPU) for too long. Prevents zombie processes waiting for input that will never come.

Client for fetching package metadata from omnipkg-metadata repo

Owns the full install lifecycle: - uv-args construction (once, shared across all paths) - start_op / end_op daemon signaling (hoisted

Pure-Python polling fallback when watchdog isn't installed. Polls every 500ms — adds latency but never panics. Production systems should

Manages 24-hour caching of PyPI versions AND compatibility information. Now stores: version, compatible_python, exists_on_pypi, error_state

Track and cleanup orphaned shared memory blocks.

A stateful pipeline for the SQLiteCacheClient that collects commands and executes them in a batch within a single transaction.

Manages a shared memory control block for Optimistic Concurrency Control. Structure Layout (128 bytes total to ensure cache line isolation):

Orchestrates package installation for OmnipkgCore. Instantiated fresh per install call via the core.smart_install() shim.

Smart verification that tests packages together when needed. This prevents issues like: - h11 failing when httpcore/httpx aren't loaded

A callable class that holds the global translation function. This structure avoids namespace collisions with libraries like PyTorch.

Manages the web bridge as a background service.

Abstract base class for a file lock object.

An abstract base class for cache clients.

A context manager to safely and temporarily override omnipkg's configuration for the duration of a test or a specific operation.

Singleton perf logger. Activated by OMNIPKG_DEBUG=1. Usage: _perf = DispatchPerfLogger.get() if _perf: _perf.rec

Context manager inserted around every FFI call in the UV worker. Usage in worker_daemon.py's run_uv handler: from omnipkg.isolation

A dataclass which holds the context for a ``BaseFileLock`` object.

Types of verification hooks.

Detect available IPC methods on the system.

Fake collector for test_old_rich.py. Instead of actually importing the file (which would trigger the AssertionError), we return a single

The runtime healer that automatically fixes import errors.

Thin wrapper around a 128-byte shared-memory block. The dirty flag acts as a read-write gate: Writers (watcher): mark_dirty() → in

Automatically selects best available GPU IPC method. Graceful degradation: native_1x > custom > hybrid

Simply watches the existence of the lock file.

Runs commands in a highly isolated shell to prevent terminal corruption. Uses 'stty sane' to restore terminal if a C++ library crashes hard.