Batches: Do not attempt to cancel non-existing tref. Closes celery#1984

ant31 · Apr 15, 2014 · 7289933 · 7289933
1 parent 5383f21
commit 7289933
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/celery/contrib/batches.py b/celery/contrib/batches.py
@@ -226,7 +226,8 @@ def _do_flush(self):
                 self.flush(requests)
         if not requests:
             logger.debug('Batches: Cancelling timer: Nothing in buffer.')
-            self._tref.cancel()  # cancel timer.
+            if self._tref:
+                self._tref.cancel()  # cancel timer.
             self._tref = None
 
     def apply_buffer(self, requests, args=(), kwargs={}):