Functions — github.com/1minds3t/omnipkg

CodeHub MCPcopy Index your code

hub / github.com/1minds3t/omnipkg / functions

Functions1,775 in github.com/1minds3t/omnipkg

⨍ Functions 1,775◇ Types & classes 163↳ Endpoints 4

↓ 3,544 callersFunctionsafe_print

Ultra-robust print: Handles Windows encoding issues and prevents shell crashes. Detects non-UTF8 sessions (like cp1252) and strips emojis to

src/omnipkg/common_utils.py:26

↓ 798 callersFunctionprint

(*args, **kwargs)

src/omnipkg/utils/ai_import_healer.py:426

↓ 733 callersMethodexists

src/omnipkg/cache.py:34

↓ 656 callersMethodget

src/omnipkg/isolation/worker_daemon.py:607

↓ 493 callersFunctionsafe_print

src/omnipkg/isolation/patchers.py:27

↓ 370 callersMethodget

Get a configuration value, with an optional default.

src/omnipkg/core.py:3409

↓ 364 callersMethodget

src/omnipkg/cache.py:28

↓ 206 callersFunctionsafe_print

(message, **kwargs)

src/omnipkg/tests/test_flask_port_finder.py:41

↓ 179 callersMethodrun

(self, spec: str, code_to_run: str)

src/omnipkg/isolation/switchers.py:24

↓ 142 callersMethodwrite

Write text, but filter out nuked patterns.

src/omnipkg/utils/warning_silencer.py:46

↓ 96 callersFunction_safe_print

Lazy _safe_print — only imported on error paths.

src/omnipkg/dispatcher.py:24

↓ 77 callersMethodkeys

(self, pattern)

src/omnipkg/cache.py:43

↓ 73 callersMethodunlink

src/omnipkg/cache.py:40

↓ 71 callersMethodload

src/omnipkg/isolation/gpu_ipc.py:89

↓ 62 callersMethod_profile_end

End timing and optionally print. FIXED: Now respects self._profiling_enabled for ALL output, including print_now=self._profi

src/omnipkg/loader.py:425

↓ 54 callersMethodclose

src/omnipkg/isolation/fs_watcher.py:250

↓ 47 callersFunctionsafe_input

Safe input wrapper with three operating modes: # --- GLOBAL INTERACTIVE MONKEYPATCH --- # If we are running as a daemon worker, we MUST hijack t

src/omnipkg/common_utils.py:799

↓ 46 callersFunctionprint_with_flush

Print with immediate flush.

src/omnipkg/tests/test_version_combos.py:23

↓ 43 callersMethod_profile_start

Start timing a profiled section

src/omnipkg/loader.py:420

↓ 40 callersMethodflush

Flush the original stderr.

src/omnipkg/utils/warning_silencer.py:62

↓ 38 callersMethodunlink

src/omnipkg/isolation/fs_watcher.py:256

↓ 36 callersFunctionparse_version

src/omnipkg/commands/run.py:113

↓ 32 callersFunctionsafe_print

(*args, **kwargs)

src/omnipkg/utils/flask_port_finder.py:46

↓ 30 callersMethodtouch

Mark the cache as dirty. Called after every FS mutation.

src/omnipkg/isolation/fs_lock_queue.py:296

↓ 28 callersMethodexecute_shm

Low-level execute with explicit SHM metadata. Prefer execute_smart() for all normal use - it picks the right transport automa

src/omnipkg/isolation/worker_daemon.py:6441

↓ 28 callersMethodforce_shutdown

Forcefully shutdown worker using a belt-and-suspenders approach.

src/omnipkg/isolation/worker_daemon.py:3366

↓ 28 callersMethodset

Set a configuration value for the current environment and save.

src/omnipkg/core.py:3413

↓ 27 callersMethodexecute

Run Python code in the worker.

src/omnipkg/isolation/workers.py:229

↓ 26 callersMethodexecute

Executes all queued commands in a transaction and returns results.

src/omnipkg/cache.py:366

↓ 26 callersFunctionfail

(label, reason)

src/omnipkg/tests/omnipkg_ipc_showcase.py:80

↓ 26 callersMethodrun

tests/test_omnipkg_contracts.py:192

↓ 25 callersFunctionglog

src/omnipkg/ghost.c:31

↓ 25 callersMethodstatus

src/omnipkg/isolation/worker_daemon.py:6476

↓ 24 callersMethodexecute_cuda_ipc

Execute code with GPU IPC using specified mode. Args: ipc_mode: 'auto', 'universal', 'pytorch_native', 'cpu_shm', or 'hy

src/omnipkg/isolation/worker_daemon.py:6917

↓ 24 callersFunctionok

(label, ms, extra="")

src/omnipkg/tests/omnipkg_ipc_showcase.py:73

↓ 23 callersMethodexecute

(self, code: str)

src/omnipkg/isolation/worker_daemon.py:7631

↓ 23 callersMethodexecute_zero_copy

HFT MODE: Zero-Copy Tensor Handoff via Shared Memory.

src/omnipkg/isolation/worker_daemon.py:7419

↓ 22 callersFunction_ok

(label: str, detail: str = "")

tests/test_uv_ffi_contracts.py:78

↓ 21 callersFunction_header

tests/test_uv_ffi_contracts.py:75

↓ 21 callersMethodclose

src/omnipkg/isolation/worker_daemon.py:507

↓ 21 callersFunctionfile_exists

src/omnipkg/dispatcher.c:322

↓ 21 callersFunctionis_interactive_session

Returns True only for real interactive terminal sessions. Returns False for: CI, Docker, piped input, explicitly non-interactive envs, an

src/omnipkg/common_utils.py:699

↓ 21 callersMethodsmart_install

(self, packages, dry_run=False, force_reinstall=False, override_strategy=None, target_direct

src/omnipkg/core.py:12239

↓ 21 callersMethodstart

Starts the daemon, handling platform differences and waiting logic.

src/omnipkg/isolation/worker_daemon.py:3572

↓ 20 callersMethodexecute

Execute Python code in the activated environment. Works transparently in both worker and in-process modes. Args:

src/omnipkg/loader.py:5543

↓ 19 callersMethod_verify_python_version

Verify that a Python executable works and get its version. Returns (major, minor) tuple or None if invalid.

src/omnipkg/core.py:2296

↓ 19 callersFunctiont

src/omnipkg/tests/omnipkg_ipc_showcase.py:92

↓ 19 callersMethodunlink

src/omnipkg/isolation/worker_daemon.py:514

↓ 18 callersMethodhget

(self, key, field)

src/omnipkg/cache.py:52

↓ 18 callersMethodlist_available_interpreters

Returns a dict of version -> path for all available interpreters. Now uses an in-memory cache that can be refreshed. THREAD-S

src/omnipkg/core.py:3444

↓ 17 callersFunction_info

tests/test_uv_ffi_contracts.py:84

↓ 17 callersMethod_parse_package_spec

Parse a package specification like 'package==1.0.0' or 'package>=2.0' Returns (package_name, version) where version is None if no ver

src/omnipkg/core.py:13225

↓ 17 callersMethodfileno

Return the file descriptor of original stderr.

src/omnipkg/utils/warning_silencer.py:76

↓ 17 callersMethodrun

↓ 17 callersFunctionskip

(label, reason)

src/omnipkg/tests/omnipkg_ipc_showcase.py:86

↓ 16 callersFunctiondaemon_restart

Kill all workers and wait for the daemon to be back up. We suppress output – only print if it fails.

src/omnipkg/tests/omnipkg_ipc_showcase.py:98

↓ 16 callersMethodpipeline

src/omnipkg/cache.py:46

↓ 16 callersMethodrename

Atomically rename src → dst under the scan guard. Returns True on success, False if src has vanished (another process already

src/omnipkg/isolation/fs_lock_queue.py:159

↓ 16 callersFunctionsection

src/omnipkg/tests/omnipkg_ipc_showcase.py:67

↓ 16 callersFunctionsend_json

Sends a JSON dictionary over a socket with timeout protection.

src/omnipkg/isolation/worker_daemon.py:564

↓ 15 callersFunction_normalize_exe

Normalize a Python executable path for reliable cross-platform comparison. On Windows, Path.resolve() is needed for drive-letter/junction can

src/omnipkg/isolation/worker_daemon.py:45

↓ 15 callersMethod_parse_package_spec

src/omnipkg/installation/smart_install.py:224

↓ 15 callersFunction_platform_info

tests/test_flask_port_finder.py:86

↓ 15 callersMethod_send

Fixed version that works on Windows and Unix

src/omnipkg/isolation/worker_daemon.py:6649

↓ 15 callersFunctioncold_warm_header

Print the cold/warm legend once per test group.

src/omnipkg/tests/omnipkg_ipc_showcase.py:123

↓ 15 callersMethodflush

Write dirty cache to disk. Call this at process exit or after a batch of writes.

src/omnipkg/core.py:16926

↓ 15 callersFunctionresolve_python_path

Resolve a Python version string to an actual interpreter path. NEW BEHAVIOR: First checks if the CURRENT executable's config knows about

src/omnipkg/dispatcher.py:1429

↓ 14 callersMethoddelete

src/omnipkg/cache.py:37

↓ 14 callersFunctionprint_header

Prints a consistent, pretty header.

src/omnipkg/common_utils.py:629

↓ 13 callersFunctionfmt

src/omnipkg/tests/test_tensorflow_switching.py:119

↓ 13 callersFunctionformat_duration

src/omnipkg/tests/test_concurrent_install.py:24

↓ 13 callersMethodhset

(self, key, field, value, mapping=None)

src/omnipkg/cache.py:16

↓ 13 callersMethodset

(self, key, value, ex=None)

src/omnipkg/cache.py:31

↓ 12 callersMethod_connect_cache

Establishes a cache connection. Auto-corrects misconfigurations gracefully.

src/omnipkg/core.py:7512

↓ 12 callersMethodadopt_interpreter

Safely adopts a Python version by checking the registry, then trying to copy from the local system, and finally falling back to downl

src/omnipkg/core.py:10778

↓ 12 callersMethodcache_version

Cache version information. File write is deferred until flush().

src/omnipkg/core.py:16836

↓ 12 callersMethodget_interpreter_for_version

Get the path to a specific Python interpreter version from the registry.

src/omnipkg/core.py:1177

↓ 12 callersFunctionget_version

Get version from package metadata.

src/omnipkg/cli.py:314

↓ 12 callersMethodhgetall

src/omnipkg/cache.py:13

↓ 11 callersFunction_assert_exec_ok

Assert that a daemon execute() call succeeded.

tests/test_omnipkg_contracts.py:87

↓ 11 callersFunctioncorsify_response

Adds CORS headers if the origin is allowed.

src/omnipkg/apis/local_bridge.py:389

↓ 11 callersFunctionensure_daemon_running

Start the daemon if it isn't already running, then poll until it answers. Safe to call from any context — uses subprocess so the current proc

src/omnipkg/tests/test_loader_stress_test.py:103

↓ 11 callersMethodexecute_smart

THE ONE METHOD YOU NORMALLY CALL. Runs ``code`` inside a persistent worker that has ``spec`` installed, automatically choos

src/omnipkg/isolation/worker_daemon.py:7486

↓ 11 callersFunctionsafe_uncloak

Rename src → dst (uncloak / restore) under the dual lock. Returns True if the rename happened OR if src was already gone (meaning anothe

src/omnipkg/isolation/fs_lock_queue.py:232

↓ 10 callersMethod_aggressive_module_cleanup

Removes specified package's modules from sys.modules. Special handling for torch which cannot be fully cleaned. FIXED: All p

src/omnipkg/loader.py:4685

↓ 10 callersFunction_relative_to_win

Case-insensitive relative_to that works across Windows drive letter normalization.

src/omnipkg/common_utils.py:948

↓ 10 callersMethodcall

src/omnipkg/tests/benchmark_transport.py:252

↓ 10 callersFunctiondebug

docs/assets/js/interact.js:18

↓ 10 callersFunctiondump_daemon_log

Dump last max_lines of daemon log. By default only prints if the log contains ERROR/EXCEPTION.

src/omnipkg/tests/test_concurrent_install.py:33

↓ 10 callersFunctionfmt

src/omnipkg/tests/test_daemon_tags.py:77

↓ 10 callersFunctionget_tmp_dir

── stamp-file helpers ─────────────────────────────────────────────────── */ * Stamp file: /tmp/omnipkg/ffi_ok/<djb2hash>.stamp * Presence = uv_ffi v

src/omnipkg/dispatcher.c:1190

↓ 10 callersMethodhdel

(self, key, *fields)

src/omnipkg/cache.py:55

↓ 10 callersMethodrefresh_registry

FIX: Clears the in-memory cache of interpreters, forcing a re-read from disk on the next call.

src/omnipkg/core.py:3437

↓ 10 callersMethodrelease

Releases the file lock. Please note, that the lock is only completely released, if the lock counter is 0. Also note, that the lock fi

src/omnipkg/_vendor/filelock/_api.py:231

↓ 10 callersMethodstart

src/omnipkg/loader.py:147

↓ 10 callersMethodversion

src/omnipkg/isolation/fs_watcher.py:190

↓ 9 callersMethod_dbg_print

(self, msg, **kwargs)

src/omnipkg/installation/installers.py:792

↓ 9 callersFunction_fail

(label: str, detail: str = "")

tests/test_uv_ffi_contracts.py:81

↓ 9 callersMethod_fallback_to_download

Fallback to downloading Python. This function now surgically detects an incomplete installation by checking for a valid executable, c

src/omnipkg/core.py:11108

↓ 9 callersMethod_get_file_hash

(self, file_path: Path)

src/omnipkg/core.py:5821

next →1–100 of 1,775, ranked by callers