.gitignore
LICENSE
PIPE_REFERENCE.md
PLANNED.md
README.md
pyproject.toml
.github/workflows/tests.yml
.github/workflows/wheels.yml
bench/bench_batch_accumulation.py
bench/bench_passthrough.py
bench/bench_pipe_overhead.py
bench/bench_queue_throughput.py
bench/bench_shmqueue.py
docs/retry.md
examples/README.md
examples/basic_download.py
examples/batch_s3_upload.py
examples/ddp_training.py
examples/demo.py
examples/gpu_inference.py
examples/group_by_key.py
examples/multi_stage_encode.py
examples/retry_downloader.py
examples/s3_downloader.py
examples/training_dataloader.py
examples/planned/autoscale_demo.py
rust/Cargo.lock
rust/Cargo.toml
rust/src/lib.rs
rust/src/ring.rs
rust/src/store.rs
rust/src/sys.rs
scripts/bench_chunking.py
scripts/check_dist.py
scripts/check_wheel.py
src/gpupipe.egg-info/PKG-INFO
src/gpupipe.egg-info/SOURCES.txt
src/gpupipe.egg-info/dependency_links.txt
src/gpupipe.egg-info/requires.txt
src/gpupipe.egg-info/scm_file_list.json
src/gpupipe.egg-info/scm_version.json
src/gpupipe.egg-info/top_level.txt
src/pipe/__init__.py
src/pipe/_torch.py
src/pipe/_version.py
src/pipe/lifecycle.py
src/pipe/monitors.py
src/pipe/pipe.py
src/pipe/profiling.py
src/pipe/py.typed
src/pipe/queues.py
src/pipe/scavenge.py
src/pipe/sequential.py
src/pipe/shmqueue.py
src/pipe/shmstore.py
src/pipe/types.py
src/pipe/utils.py
src/pipe/web.py
src/pipe/workers.py
src/pipe/_planned/__init__.py
src/pipe/_planned/autoscale.py
tests/conftest.py
tests/test_basic.py
tests/test_batching.py
tests/test_chunking.py
tests/test_cpu_affinity.py
tests/test_drain.py
tests/test_edge_cases.py
tests/test_generators.py
tests/test_gpu_pool.py
tests/test_gpu_release.py
tests/test_new_features.py
tests/test_no_torch.py
tests/test_observability.py
tests/test_pipeline_patterns.py
tests/test_planned_preserved.py
tests/test_push_retry.py
tests/test_push_stress.py
tests/test_scavenge.py
tests/test_shmqueue.py
tests/test_shmstore.py
tests/test_stats_display.py
tests/test_stress.py
tests/test_tensor.py
tests/test_utils.py
tests/test_web.py
tests/test_workers.py
tests/planned/test_autoscale.py