LICENCE.md
README.md
pyproject.toml
src/dpypeline/__init__.py
src/dpypeline.egg-info/PKG-INFO
src/dpypeline.egg-info/SOURCES.txt
src/dpypeline.egg-info/dependency_links.txt
src/dpypeline.egg-info/requires.txt
src/dpypeline.egg-info/top_level.txt
src/dpypeline/akita/__init__.py
src/dpypeline/akita/core.py
src/dpypeline/akita/directory_state.py
src/dpypeline/akita/event_handler.py
src/dpypeline/akita/factory.py
src/dpypeline/akita/queue_events.py
src/dpypeline/celery/__init__.py
src/dpypeline/celery/app.py
src/dpypeline/celery/config.py
src/dpypeline/celery/tasks/__init__.py
src/dpypeline/celery/tasks/xarray.py
src/dpypeline/etl_pipeline/__init__.py
src/dpypeline/etl_pipeline/celery_pipeline.py
src/dpypeline/etl_pipeline/core.py
src/dpypeline/etl_pipeline/decorators.py
src/dpypeline/etl_pipeline/thread_pipeline.py
src/dpypeline/event_consumer/__init__.py
src/dpypeline/event_consumer/core.py
src/dpypeline/filesystems/__init__.py
src/dpypeline/filesystems/object_store.py
tests/test_queue.py