__init__.py
celery_app.py
pipeline_tasks.py