| 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() | |