Skip to content

Latest commit

 

History

History
16 lines (13 loc) · 490 Bytes

README.md

File metadata and controls

16 lines (13 loc) · 490 Bytes
Raw

About

This project is an example project that complements a blog post about how to implement a job scheduler for traversing DAG of tasks in Python's Celery

How to run

Dependencies

  1. MySQL 5.6+
  2. RabbitMQ
  3. Python 3

Steps

  1. git clone [email protected]:pavloo/dag-traverse-celery-example.git
  2. cd dag-traverse-celery-example
  3. pip install -r requirements.txt
  4. celery worker -A dag.task -Q queue-1
  5. python -m dag.run