Explorar el Código

Fixes bug in TaskProducer (deprecated class)

Ask Solem hace 12 años
padre
commit
cbaaeda8f6
Se han modificado 1 ficheros con 1 adiciones y 0 borrados
  1. 1 0
      celery/app/amqp.py

+ 1 - 0
celery/app/amqp.py

@@ -166,6 +166,7 @@ class TaskProducer(Producer):
     auto_declare = False
     auto_declare = False
     retry = False
     retry = False
     retry_policy = None
     retry_policy = None
+    utc = True
 
 
     def __init__(self, channel=None, exchange=None, *args, **kwargs):
     def __init__(self, channel=None, exchange=None, *args, **kwargs):
         self.retry = kwargs.pop('retry', self.retry)
         self.retry = kwargs.pop('retry', self.retry)