integrated pipeline via dramatiq
Showing
- README.md 8 additions, 0 deletionsREADME.md
- celery-test.sh 0 additions, 28 deletionscelery-test.sh
- drama.py 4 additions, 0 deletionsdrama.py
- requirements.txt 3 additions, 2 deletionsrequirements.txt
- server/api/routes/imports.py 14 additions, 14 deletionsserver/api/routes/imports.py
- server/api/routes/ping.py 13 additions, 0 deletionsserver/api/routes/ping.py
- server/api/routes/pipelines.py 30 additions, 1 deletionserver/api/routes/pipelines.py
- server/pipelines/actor.py 142 additions, 0 deletionsserver/pipelines/actor.py
- server/pipelines/tasks/__init__.py 15 additions, 133 deletionsserver/pipelines/tasks/__init__.py
- server/pipelines/tasks/imports.py 62 additions, 51 deletionsserver/pipelines/tasks/imports.py
- server/pipelines/tasks/sleepy.py 32 additions, 0 deletionsserver/pipelines/tasks/sleepy.py
Loading
Please register or sign in to comment