.gitignore
LICENSE
PIPE_REFERENCE.md
PLANNED.md
README.md
pyproject.toml
bench/bench_batch_accumulation.py
bench/bench_queue_throughput.py
docs/retry.md
docs/examples/README.md
docs/examples/basic_download.py
docs/examples/batch_s3_upload.py
docs/examples/ddp_training.py
docs/examples/gpu_inference.py
docs/examples/group_by_key.py
docs/examples/multi_stage_encode.py
docs/examples/retry_downloader.py
docs/examples/s3_downloader.py
docs/examples/training_dataloader.py
examples/demo.py
examples/planned/autoscale_demo.py
scripts/bench_chunking.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/_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/sequential.py
src/pipe/shm.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_new_features.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_shm.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