Move the actual celery task from processing/__init__.py into its own .../task.py. That way it can be imported as needed.