-
- Downloads
many changes to add the ability to create queued runs on celery on separate pipelines with one app
Showing
- src/pypelines/__init__.py 1 addition, 1 deletionsrc/pypelines/__init__.py
- src/pypelines/arguments.py 6 additions, 4 deletionssrc/pypelines/arguments.py
- src/pypelines/celery_tasks.py 192 additions, 0 deletionssrc/pypelines/celery_tasks.py
- src/pypelines/disk.py 4 additions, 4 deletionssrc/pypelines/disk.py
- src/pypelines/graphs.py 12 additions, 8 deletionssrc/pypelines/graphs.py
- src/pypelines/pickle_backend.py 8 additions, 4 deletionssrc/pypelines/pickle_backend.py
- src/pypelines/pipelines.py 14 additions, 36 deletionssrc/pypelines/pipelines.py
- src/pypelines/pipes.py 1 addition, 6 deletionssrc/pypelines/pipes.py
- src/pypelines/steps.py 53 additions, 25 deletionssrc/pypelines/steps.py
- src/pypelines/tasks.py 17 additions, 119 deletionssrc/pypelines/tasks.py
Loading
Please register or sign in to comment