flush redis between tests

Author: steinitzu

tests/test_backends.py

@@ -27,7 +27,7 @@ def backend(redis_url):
     try:
         yield backend
     finally:
-        clear_locks(backend)
+        backend.redis.flushall()
         backends._backend = None
 
 

tests/test_singleton.py

@@ -8,6 +8,8 @@
 from celery_singleton.singleton import Singleton, clear_locks
 from celery_singleton import util, DuplicateTaskError
 from celery_singleton.backends.redis import RedisBackend
+from celery_singleton.backends import get_backend
+from celery_singleton.config import Config
 
 
 @pytest.fixture(scope="session")
@@ -30,7 +32,8 @@ def scoped_app(celery_app):
     try:
         yield celery_app
     finally:
-        clear_locks(celery_app)
+        backend = get_backend(Config(celery_app))
+        backend.redis.flushall()
 
 
 class ExpectedTaskFail(Exception):