Must import dateutil.parser directly.

celery/worker/__init__.py

@@ -8,7 +8,7 @@ import logging
 import socket
 from Queue import Queue
 
-import dateutil
+from dateutil.parser import parse as parse_iso8601
 from carrot.connection import DjangoBrokerConnection, AMQPConnectionException
 
 from celery import conf
@@ -107,7 +107,7 @@ class CarrotListener(object):
 
         eta = message_data.get("eta")
         if eta:
-            eta = dateutil.parser.parse(eta)
+            eta = parse_iso8601(eta)
             self.prefetch_count.increment()
             self.logger.info("Got task from broker: %s[%s] eta:[%s]" % (
                     task.task_name, task.task_id, eta))