code: def cli(*, worker_settings, burst, check, watch, verbose):
      
      sys.path.append(os.getcwd())
      worker_settings = import_string(worker_settings)
      logging.config.dictConfig(default_log_config(verbose))
  
      if check:
          exit(check_health(worker_settings))
      else:
          kwargs = {} if burst is None else {'burst': burst}
          if watch:
              loop = asyncio.get_event_loop()
              loop.run_until_complete(watch_reload(watch, worker_settings, loop))
          else:
              run_worker(worker_settings, **kwargs)
docs: Job queues in python with asyncio and redis.
  
      CLI to run the arq worker.