Rewrote to use a cleaner API and standard celery commands