Logger.warn is deprecated

celery/backends/cassandra.py

@@ -111,7 +111,7 @@ class CassandraBackend(BaseDictBackend):
                     Thrift.TException), exc:
                 if time.time() > ts:
                     raise
-                logger.warn('Cassandra error: %r. Retrying...', exc)
+                logger.warning('Cassandra error: %r. Retrying...', exc)
                 time.sleep(self._retry_wait)
 
     def _get_column_family(self):

celery/worker/consumer.py

@@ -162,7 +162,7 @@ Will retry using next failover.\
 task_reserved = state.task_reserved
 
 logger = get_logger(__name__)
-info, warn, error, crit = (logger.info, logger.warn,
+info, warn, error, crit = (logger.info, logger.warning,
                            logger.error, logger.critical)
 
 

celery/worker/job.py

@@ -40,7 +40,7 @@ from . import state
 
 logger = get_logger(__name__)
 debug, info, warn, error = (logger.debug, logger.info,
-                            logger.warn, logger.error)
+                            logger.warning, logger.error)
 _does_info = False
 _does_debug = False