diff options
| author | Josh Cohen <joshuasteelers@me.com> | 2021-09-13 07:50:35 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-09-13 18:50:35 +0700 |
| commit | 0d69d081264b8465d93d8447853e777e85573a34 (patch) | |
| tree | b3f5c215b67d114f234292f8330a3fbb1e146740 | |
| parent | a3fba1ca1fb16599cd775265f060697a07f5866f (diff) | |
| download | rq-0d69d081264b8465d93d8447853e777e85573a34.tar.gz | |
RPass serializer to queue at cli (#1556)
| -rwxr-xr-x | rq/cli/cli.py | 11 | ||||
| -rw-r--r-- | rq/version.py | 2 |
2 files changed, 8 insertions, 5 deletions
diff --git a/rq/cli/cli.py b/rq/cli/cli.py index ab16b54..d79d214 100755 --- a/rq/cli/cli.py +++ b/rq/cli/cli.py @@ -100,16 +100,18 @@ def main(): @click.option('--all', '-a', is_flag=True, help='Empty all queues') @click.argument('queues', nargs=-1) @pass_cli_config -def empty(cli_config, all, queues, **options): +def empty(cli_config, all, queues, serializer, **options): """Empty given queues.""" if all: queues = cli_config.queue_class.all(connection=cli_config.connection, - job_class=cli_config.job_class) + job_class=cli_config.job_class, + serializer=serializer) else: queues = [cli_config.queue_class(queue, connection=cli_config.connection, - job_class=cli_config.job_class) + job_class=cli_config.job_class, + serializer=serializer) for queue in queues] if not queues: @@ -249,7 +251,8 @@ def worker(cli_config, burst, logging_level, name, results_ttl, queues = [cli_config.queue_class(queue, connection=cli_config.connection, - job_class=cli_config.job_class) + job_class=cli_config.job_class, + serializer=serializer) for queue in queues] worker = cli_config.worker_class( queues, name=name, connection=cli_config.connection, diff --git a/rq/version.py b/rq/version.py index 9c9b3a9..4c7666c 100644 --- a/rq/version.py +++ b/rq/version.py @@ -2,4 +2,4 @@ from __future__ import (absolute_import, division, print_function, unicode_literals) -VERSION = '1.10.0' +VERSION = '1.10.1' |