Browse Source

Update task queue command to support windows

pull/1552/head
Hironsan 2 years ago
parent
commit
4e18b0c1cb
1 changed files with 15 additions and 10 deletions
  1. 25
      backend/cli.py

25
backend/cli.py

@ -17,6 +17,10 @@ def number_of_workers():
return (multiprocessing.cpu_count() * 2) + 1 return (multiprocessing.cpu_count() * 2) + 1
def is_windows():
return platform.system() == 'Windows'
def run_on_nix(args): def run_on_nix(args):
import gunicorn.app.base import gunicorn.app.base
import gunicorn.util import gunicorn.util
@ -68,7 +72,7 @@ def command_user_create(args):
def command_run_webserver(args): def command_run_webserver(args):
print(f'Starting server with port {args.port}.') print(f'Starting server with port {args.port}.')
if platform.system() == 'Windows':
if is_windows():
run_on_windows(args) run_on_windows(args)
else: else:
run_on_nix(args) run_on_nix(args)
@ -76,15 +80,16 @@ def command_run_webserver(args):
def command_run_task_queue(args): def command_run_task_queue(args):
print('Starting task queue.') print('Starting task queue.')
app.worker_main(
argv=[
'--app=app',
'--workdir={}'.format(base),
'worker',
'--loglevel=info',
'--concurrency={}'.format(args.concurrency),
]
)
argv = [
'--app=app',
'--workdir={}'.format(base),
'worker',
'--loglevel=info',
'--concurrency={}'.format(args.concurrency)
]
if is_windows():
argv.append('--pool=solo')
app.worker_main(argv=argv)
def command_help(args): def command_help(args):

Loading…
Cancel
Save