LICENSE
README.md
pyproject.toml
src/zoopipe/__init__.py
src/zoopipe/core.py
src/zoopipe/exceptions.py
src/zoopipe/logger.py
src/zoopipe/report.py
src/zoopipe/utils.py
src/zoopipe.egg-info/PKG-INFO
src/zoopipe.egg-info/SOURCES.txt
src/zoopipe.egg-info/dependency_links.txt
src/zoopipe.egg-info/requires.txt
src/zoopipe.egg-info/top_level.txt
src/zoopipe/executor/__init__.py
src/zoopipe/executor/base.py
src/zoopipe/executor/dask.py
src/zoopipe/executor/multiprocessing.py
src/zoopipe/executor/ray.py
src/zoopipe/executor/sync_fifo.py
src/zoopipe/executor/thread.py
src/zoopipe/hooks/__init__.py
src/zoopipe/hooks/base.py
src/zoopipe/hooks/builtin.py
src/zoopipe/hooks/partitioned.py
src/zoopipe/input_adapter/__init__.py
src/zoopipe/input_adapter/arrow.py
src/zoopipe/input_adapter/base.py
src/zoopipe/input_adapter/base_async.py
src/zoopipe/input_adapter/csv.py
src/zoopipe/input_adapter/json.py
src/zoopipe/input_adapter/partitioner.py
src/zoopipe/input_adapter/queue.py
src/zoopipe/models/__init__.py
src/zoopipe/models/core.py
src/zoopipe/output_adapter/__init__.py
src/zoopipe/output_adapter/arrow.py
src/zoopipe/output_adapter/base.py
src/zoopipe/output_adapter/base_async.py
src/zoopipe/output_adapter/csv.py
src/zoopipe/output_adapter/dummy.py
src/zoopipe/output_adapter/generator.py
src/zoopipe/output_adapter/json.py
src/zoopipe/output_adapter/memory.py
src/zoopipe/output_adapter/queue.py
tests/test_async_bridge.py
tests/test_async_queue.py
tests/test_background_run.py
tests/test_binary_compression.py
tests/test_csv.py
tests/test_custom_id_generator.py
tests/test_dask.py
tests/test_dask_streaming.py
tests/test_dummy_output.py
tests/test_hook_errors.py
tests/test_hooks.py
tests/test_json_input.py
tests/test_json_output.py
tests/test_multiprocessing.py
tests/test_new_features.py
tests/test_no_pydantic.py
tests/test_output_csv.py
tests/test_process_control.py
tests/test_pyarrow_adapter.py
tests/test_ray.py
tests/test_report.py
tests/test_sync_fifo.py
tests/test_sync_queue_adapters.py
tests/test_thread.py