fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-10-05 03:38:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fixes relative imports

Browse Source
This commit is contained in:
ilan
2018-03-13 18:32:49 +01:00
parent 62affc17bb
commit e1d1f0f099
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/brokers/__init__.py
+6 -6
View File
@@ -166,25 +166,25 @@ def get_broker(list_key=Conf.PREFIX):
return broker(list_key=list_key) return broker(list_key=list_key)
# disque # disque
elif Conf.DISQUE_NODES: elif Conf.DISQUE_NODES:
from brokers import disque from django_q.brokers import disque
return disque.Disque(list_key=list_key) return disque.Disque(list_key=list_key)
# Iron MQ # Iron MQ
elif Conf.IRON_MQ: elif Conf.IRON_MQ:
from brokers import ironmq from django_q.brokers import ironmq
return ironmq.IronMQBroker(list_key=list_key) return ironmq.IronMQBroker(list_key=list_key)
# SQS # SQS
elif Conf.SQS: elif Conf.SQS:
from brokers import aws_sqs from django_q.brokers import aws_sqs
return aws_sqs.Sqs(list_key=list_key) return aws_sqs.Sqs(list_key=list_key)
# ORM # ORM
elif Conf.ORM: elif Conf.ORM:
from brokers import orm from django_q.brokers import orm
return orm.ORM(list_key=list_key) return orm.ORM(list_key=list_key)
# Mongo # Mongo
elif Conf.MONGO: elif Conf.MONGO:
from brokers import mongo from django_q.brokers import mongo
return mongo.Mongo(list_key=list_key) return mongo.Mongo(list_key=list_key)
# default to redis # default to redis
else: else:
from brokers import redis_broker from django_q.brokers import redis_broker
return redis_broker.Redis(list_key=list_key) return redis_broker.Redis(list_key=list_key)