| 63 | |
| 64 | |
| 65 | def start_services(): |
| 66 | services = args.services if isinstance(args.services, list) else [args.services] |
| 67 | start_args = [] |
| 68 | if args.daemon: |
| 69 | start_args.append('--daemon') |
| 70 | if args.force: |
| 71 | start_args.append('--force') |
| 72 | if args.worker: |
| 73 | start_args.extend(['--worker', str(args.worker)]) |
| 74 | else: |
| 75 | worker = os.environ.get('MAXKB_CORE_WORKER') |
| 76 | if isinstance(worker, str) and worker.isdigit(): |
| 77 | start_args.extend(['--worker', worker]) |
| 78 | |
| 79 | try: |
| 80 | management.call_command(action, *services, *start_args) |
| 81 | except KeyboardInterrupt: |
| 82 | logging.info('Cancel ...') |
| 83 | time.sleep(2) |
| 84 | except Exception as exc: |
| 85 | logging.error("Start service error {}: {}".format(services, exc)) |
| 86 | time.sleep(2) |
| 87 | |
| 88 | |
| 89 | def dev(): |