File size: 312 Bytes
395201c |
1 2 3 4 5 6 7 8 9 10 11 12 |
import os
from multiprocessing import Process
def run_worker(cwd):
os.chdir(cwd)
os.system("celery -A celery_app.celery_app worker --concurrency=120 --loglevel=info")
def start_worker(cwd):
cwd += "/queue"
worker_process = Process(target=run_worker, args=(cwd,))
worker_process.start()
|