# Path: mrq/redishelpers.py
# def redis_key(name, *args):
#   prefix = context.get_current_config()["redis_prefix"]
#   if name == "known_subqueues":
#     return "%s:ksq:%s" % (prefix, args[0].root_id)
#   elif name == "queue":
#      return "%s:q:%s" % (prefix, args[0].id)
#   elif name == "started_jobs":
#     return "%s:s:started" % prefix
#   elif name == "paused_queues":
#     return "%s:s:paused" % prefix
#   elif name == "notify":
#      return "%s:notify:%s" % (prefix, args[0].root_id)


from future.builtins import bytes, str, object
from bson import ObjectId
from . import context
from . import job as jobmodule
from .redishelpers import redis_key
from future import standard_library
from itertools import chain
            from .queue_regular import QueueRegular
            from .queue_raw import QueueRaw
import time
import binascii
import sys
from __future__ import division




PY3 = sys.version_info > (3,)
standard_library.install_aliases()



# Path: mrq/redishelpers.py
# def redis_key(name, *args):
#   prefix = context.get_current_config()["redis_prefix"]
#   if name == "known_subqueues":
#     return "%s:ksq:%s" % (prefix, args[0].root_id)
#   elif name == "queue":
#      return "%s:q:%s" % (prefix, args[0].id)
#   elif name == "started_jobs":
#     return "%s:s:started" % prefix
#   elif name == "paused_queues":
#     return "%s:s:paused" % prefix
#   elif name == "notify":
#      return "%s:notify:%s" % (prefix, args[0].root_id)


# Path: mrq/queue.py
from future.builtins import bytes, str, object
from bson import ObjectId
from . import context
from . import job as jobmodule
from .redishelpers import redis_key
from future import standard_library
from itertools import chain
            from .queue_regular import QueueRegular
            from .queue_raw import QueueRaw
import time
import binascii
import sys

from __future__ import division




PY3 = sys.version_info > (3,)
standard_library.install_aliases()



class Queue(object):