Merge branch 'master' of github.com:celery/celery

celery/worker/consumer.py

@@ -178,7 +178,7 @@ class Consumer(object):
             except self.connection_errors + self.channel_errors:
                 maybe_shutdown()
                 if ns.state != CLOSE and self.connection:
-                    error(CONNECTION_RETRY, exc_info=True)
+                    warn(CONNECTION_RETRY, exc_info=True)
                     ns.restart(self)
 
     def shutdown(self):