@@ -5,7 +5,6 @@ import traceback from django.core.mail import mail_admins from django.template.loader import render_to_string -from .utils.db import transaction from .utils.log import logger import .consumer as consumer @@ -32,8 +31,7 @@ class ConsumerProcess(object): def run(self, fault_tolerant=True, **kwargs): for message in self.consumer.message_iterator(**kwargs): try: - with transaction(): # commit on success - self.process_message(message) + self.process_message(message) except NotImplementedError: # Subclassing ain't happened raise consumer_process.py 3e51cfa93b0077e2d983167076cf0f225f1e8bd0 Oliver Beattie oliver@obeattie.com http://github.com/obeattie/hare/commit/902e0f4a855edaf509126a9b7b074477ce38b9e0 902e0f4a855edaf509126a9b7b074477ce38b9e0 2009-11-11T06:13:24-08:00 2009-11-11T06:13:24-08:00 Removed the dependency on Django's db system addc0398b56f1b53867c6baf05dac8e305e702b4 Oliver Beattie oliver@obeattie.com