(args: argparse.Namespace)
| 1098 | |
| 1099 | |
| 1100 | def cmd_process_run_start(args: argparse.Namespace) -> int: |
| 1101 | base_url = args.base_url.rstrip("/") |
| 1102 | _require_health(base_url, args.request_timeout) |
| 1103 | payload = _json_arg(getattr(args, "input_json", None), getattr(args, "input_file", None)) |
| 1104 | body = json.dumps({"process": args.process, "input": payload}, separators=(",", ":")).encode("utf-8") |
| 1105 | data = _request_supported_contract("POST", f"{base_url}/process-runs", timeout=args.request_timeout, data=body, headers={"Content-Type": "application/json"}) |
| 1106 | run_id = data.get("run_id") if isinstance(data, dict) else None |
| 1107 | output = {"ok": True, "base_url": base_url, "run": {"kind": "processRun", "id": str(run_id) if run_id else ""}, "status": data} |
| 1108 | if run_id: |
| 1109 | output["meta"] = _recovery_meta(base_url, str(run_id), kind="process-run") |
| 1110 | _json_print(output, compact=args.compact) |
| 1111 | return 0 |
| 1112 | |
| 1113 | |
| 1114 | def cmd_process_run_status(args: argparse.Namespace) -> int: |
nothing calls this directly
no test coverage detected