Refactored the base celery processing. Made everything resilient agains deadlock, segfaults, etc.

6 jobs for migration in 21 minutes and 39 seconds