diff --git a/mrq/agent.py b/mrq/agent.py index 3910c5cf..9bb13872 100644 --- a/mrq/agent.py +++ b/mrq/agent.py @@ -8,7 +8,12 @@ import traceback from collections import defaultdict from bson import ObjectId -from redis.lock import LuaLock + +try: + from redis.lock import LuaLock +except ImportError: + from redis.lock import Lock + from .processes import Process, ProcessPool from .utils import MovingETA, normalize_command from .queue import Queue diff --git a/mrq/worker.py b/mrq/worker.py index 31acb094..dfc4bcc1 100644 --- a/mrq/worker.py +++ b/mrq/worker.py @@ -15,7 +15,12 @@ import json as json_stdlib import ujson as json from bson import ObjectId -from redis.lock import LuaLock + +try: + from redis.lock import LuaLock +except ImportError: + from redis.lock import Lock + from collections import defaultdict from mrq.utils import load_class_by_path