code: def run_worker(cwd):
      os.chdir(cwd)
      os.system(
          "celery -A celery_app.celery_app worker --concurrency=120 --loglevel=info"
      )
  
imports: import os
  from multiprocessing import Process
label_desc: Use image node_id 1 for calling a global function with example usage: run_worker(cwd) without return types