Logger.warning is deprecated

celery/backends/cassandra.py

@@ -111,7 +111,7 @@ class CassandraBackend(BaseBackend):
                     Thrift.TException) as 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/events/state.py

@@ -47,7 +47,7 @@ Substantial drift from %s may mean clocks are out of sync.  Current drift is
 """
 
 logger = get_logger(__name__)
-warn = logger.warn
+warn = logger.warning
 
 
 def heartbeat_expires(timestamp, freq=60,

celery/worker/consumer.py

@@ -42,7 +42,7 @@ from .state import task_reserved, maybe_shutdown, revoked
 
 CLOSE = bootsteps.CLOSE
 logger = get_logger(__name__)
-debug, info, warn, error, crit = (logger.debug, logger.info, logger.warn,
+debug, info, warn, error, crit = (logger.debug, logger.info, logger.warning,
                                   logger.error, logger.critical)
 
 CONNECTION_RETRY = """\

celery/worker/job.py

@@ -41,7 +41,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