mirrors/pikasTech-apistate
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #14 from pikasTech/fix/workflow-status-summary
Pipelines as Code CI / sub2rank-nc01-cbdda6e7d9c215aa0219174596a9f33b12a6fa5e Success
Details

Browse Source 
fix: 收敛 workflow 状态默认输出
This commit is contained in:
Lyon
2026-07-17 10:19:34 +08:00
committed by GitHub
parent 1e887aa194 74b227c2b0
commit cbdda6e7d9
1 changed files with 30 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scripts/src/cli.ts
+30 -1
View File
@@ -106,6 +106,34 @@ function emit(value: Record<string, unknown>, json: boolean): void {
}
}
export function summarizeWorkflowStatus(value: Record<string, unknown>): Record<string, unknown> {
const result = record(value.result);
const summary: Record<string, unknown> = {
target: value.target,
transport: value.transport,
ok: value.ok,
workflowId: value.workflowId,
runId: value.runId,
state: value.state,
terminal: value.terminal,
error: value.error,
};
if (result) {
summary.resultOk = result.ok;
summary.resultStatus = result.status;
summary.refreshedAt = result.refreshedAt;
summary.window = result.window;
summary.groupCount = Array.isArray(result.groups) ? result.groups.length : null;
summary.accountCount = Array.isArray(result.accounts) ? result.accounts.length : null;
summary.resultFieldCount = Object.keys(result).length;
summary.disclosure = "add --json for the complete workflow result";
} else if (value.result !== null && value.result !== undefined) {
summary.resultType = Array.isArray(value.result) ? "array" : typeof value.result;
summary.disclosure = "add --json for the complete workflow result";
}
return summary;
}
function appCommand(parsed: Parsed, config: ReturnType<typeof loadConfig>): AppCommand | Record<string, unknown> {
const [group, action] = parsed.command;
if (group === "backend" && action === "check") return { kind: "backend.check" };
@@ -236,7 +264,8 @@ export async function runCli(args: string[]): Promise<void> {
if (!target) throw new Error(`runtime.cliTargets.${targetId} does not exist`);
if (parsed.overApi && target.mode !== "http") throw new Error(`--over-api requires an http target; ${targetId} is ${target.mode}`);
const result = target.mode === "embedded" ? await embedded(parsed, config, target) : await remote(parsed, config, target);
emit({ target: targetId, transport: target.mode === "embedded" ? "local-dispatcher" : "http", ...result as Record<string, unknown> }, parsed.json);
const output = { target: targetId, transport: target.mode === "embedded" ? "local-dispatcher" : "http", ...result as Record<string, unknown> };
emit(parsed.command.join(" ") === "workflow status" && !parsed.json ? summarizeWorkflowStatus(output) : output, parsed.json);
} catch (error) {
emit({ ok: false, error: error instanceof Error ? error.message : String(error), valuesPrinted: false }, wantsJson);
process.exitCode = 1;