Django 1.4, Celery Camera, Integration

gistfile1.txt

from djcelery.snapshot import Camera
from django.db import transaction

class CustomCam(Camera):

    def on_shutter(self, state, commit_every=100):
        if not state.event_count:
            if transaction.is_managed():
                transaction.commit()
            return

        def _handle_tasks():
            for i, task in enumerate(state.tasks.items()):
                self.handle_task(task)
                if not i % commit_every:
                    if transaction.is_managed():
                        transaction.commit()

        for worker in state.workers.items():
            self.handle_worker(worker)
        _handle_tasks()