chore: typo

This commit is contained in:
Ankush Menat 2022-11-25 13:10:43 +05:30
parent 4661083247
commit d00b98f460
2 changed files with 3 additions and 3 deletions

View file

@ -190,7 +190,7 @@ def start_scheduler():
@click.option(
"--strategy",
required=False,
type=click.Choice(["round_robbin", "random"]),
type=click.Choice(["round_robin", "random"]),
help="Dequeuing strategy to use",
)
def start_worker(

View file

@ -218,10 +218,10 @@ def start_worker(
rq_username: str | None = None,
rq_password: str | None = None,
burst: bool = False,
strategy: Literal["round_robbin", "random"] | None = None,
strategy: Literal["round_robin", "random"] | None = None,
) -> NoReturn | None:
"""Wrapper to start rq worker. Connects to redis and monitors these queues."""
DEQUEUE_STRATEGIES = {"round_robbin": RoundRobinWorker, "random": RandomWorker}
DEQUEUE_STRATEGIES = {"round_robin": RoundRobinWorker, "random": RandomWorker}
with frappe.init_site():
# empty init is required to get redis_queue from common_site_config.json