Private
Public Access
1
0

Merge branch 'release/v4.75'

This commit is contained in:
Sander Roosendaal
2017-11-01 22:04:03 +01:00

View File

@@ -191,8 +191,10 @@ queuefailed = Queue("failed",connection=Redis())
redis_connection = StrictRedis()
r = Redis()
client = SessionTaskListener(r,['tasks'])
client.start()
# this doesn't yet work on production
if settings.DEBUG:
client = SessionTaskListener(r,['tasks'])
client.start()
rq_registry = StartedJobRegistry(queue.name,connection=redis_connection)