Browse Source

Removes the deprecated celery.backends.pyredis module

Ask Solem 12 years ago
parent
commit
46104005ea

+ 0 - 34
celery/backends/pyredis.py

@@ -1,34 +0,0 @@
-# -*- coding: utf-8 -*-
-"""
-This is here for backwards compatibility only.
-
-Please use :class:`celery.backends.redis.RedisBackend` instead.
-
-"""
-from __future__ import absolute_import
-
-from . import redis
-
-
-class RedisBackend(redis.RedisBackend):
-
-    def __init__(self, redis_host=None, redis_port=None, redis_db=None,
-            redis_password=None, **kwargs):
-        self.redis_host = redis_host
-        self.redis_port = redis_port
-        self.redis_db = redis_db
-        self.redis_password = redis_password
-        # Changed in order to avoid duplicated arguments
-        super(RedisBackend, self).__init__(**dict(kwargs, host=redis_host,
-                                           port=redis_port, db=redis_db,
-                                           password=redis_password))
-
-    def __reduce__(self, args=(), kwargs={}):
-        # Not very useful, but without the following, the redis_* attributes
-        # would not be set.
-        kwargs.update(
-            dict(redis_host=self.redis_host,
-                 redis_port=self.redis_port,
-                 redis_db=self.redis_db,
-                 redis_password=self.redis_password))
-        return super(RedisBackend, self).__reduce__(args, kwargs)

+ 0 - 23
celery/tests/backends/test_pyredis_compat.py

@@ -1,23 +0,0 @@
-from __future__ import absolute_import
-
-from nose import SkipTest
-from pickle import loads, dumps
-
-from celery.exceptions import ImproperlyConfigured
-from celery.tests.utils import Case
-
-
-class test_RedisBackend(Case):
-
-    def test_constructor(self):
-        from celery.backends import pyredis
-        try:
-            x = pyredis.RedisBackend(redis_host="foobar", redis_port=312,
-                                    redis_db=1, redis_password="foo")
-        except ImproperlyConfigured:
-            raise SkipTest("redis-py not installed")
-        self.assertEqual(x.redis_host, "foobar")
-        self.assertEqual(x.redis_port, 312)
-        self.assertEqual(x.redis_db, 1)
-        self.assertEqual(x.redis_password, "foo")
-        self.assertTrue(loads(dumps(x)))

+ 0 - 1
contrib/release/doc4allmods

@@ -3,7 +3,6 @@
 PACKAGE="$1"
 SKIP_PACKAGES="$PACKAGE tests management urls"
 SKIP_FILES="celery.__compat__.rst
-            celery.backends.pyredis.rst
             celery.task.sets.rst
             celery.bin.rst
             celery.bin.celeryd_detach.rst