valitydev/redash
14
0
Fork 0
mirror of https://github.com/valitydev/redash.git synced 2024-11-06 17:15:17 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

support comma-separated queue lists for backward compatability (spaces are still supported) (#4937)

Browse Source
This commit is contained in:
Omer Lachish 2020-06-03 15:13:52 +03:00 committed by GitHub
parent 100c7be5e0
commit d38d3b6b4d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
redash/cli/rq.py
View File

@ -2,6 +2,7 @@ from __future__ import absolute_import
import socket import socket
import sys import sys
import datetime import datetime
from itertools import chain
from click import argument from click import argument
from flask.cli import AppGroup from flask.cli import AppGroup
@ -40,6 +41,8 @@ def worker(queues):
if not queues: if not queues:
queues = default_queues queues = default_queues
else:
queues = chain(*[queue.split(",") for queue in queues])
with Connection(rq_redis_connection): with Connection(rq_redis_connection):
w = Worker(queues, log_job_description=False, job_monitoring_interval=5) w = Worker(queues, log_job_description=False, job_monitoring_interval=5)