LICENSE
MANIFEST.in
README.md
pyproject.toml
src/fastpipe/__init__.py
src/fastpipe/_constants.py
src/fastpipe/_executors.py
src/fastpipe/_runtime.py
src/fastpipe/_stream.py
src/fastpipe/_types.py
src/fastpipe.egg-info/PKG-INFO
src/fastpipe.egg-info/SOURCES.txt
src/fastpipe.egg-info/dependency_links.txt
src/fastpipe.egg-info/requires.txt
src/fastpipe.egg-info/top_level.txt
tests/test_all_modes.py
tests/test_async_cleanup.py
tests/test_async_shutdown.py
tests/test_callable_class.py
tests/test_cleanup_exceptions.py
tests/test_concurrency_stress.py
tests/test_concurrent_pipelines.py
tests/test_executor_factory.py
tests/test_fail_fast.py
tests/test_invariants.py
tests/test_iterator.py
tests/test_partial_batch.py
tests/test_partial_batch_flush_error.py
tests/test_process_adapter.py
tests/test_process_batch.py
tests/test_process_unbatch.py
tests/test_resource_cleanup.py
tests/test_sentinel_validation.py
tests/test_stream_exceptions.py
tests/test_streaming.py
tests/test_validation_quick.py
tests/test_worker_count_mismatch.py