Potential fix for issue #289. Use manual transactions and check for is_dirty().

Author: jfischer

djcelery/snapshot.py

@@ -129,8 +129,9 @@ def update_task(self, state, **kwargs):
 
         return obj
 
+    @transaction.commit_manually
     def on_shutter(self, state, commit_every=100):
-        if not state.event_count:
+        if not state.event_count and transaction.is_dirty():
             transaction.commit()
             return
 
@@ -143,6 +144,8 @@ def _handle_tasks():
         for worker in state.workers.items():
             self.handle_worker(worker)
         _handle_tasks()
+        if transaction.is_dirty():
+            transaction.commit()
 
     def on_cleanup(self):
         expired = (self.TaskState.objects.expire_by_states(states, expires)