Restructuring celery tasks to better accommodate parallel execution.