diff --git a/internal/mcp/tools/spark_submit.go b/internal/mcp/tools/spark_submit.go index c9e6489..4be2493 100644 --- a/internal/mcp/tools/spark_submit.go +++ b/internal/mcp/tools/spark_submit.go @@ -176,6 +176,8 @@ func (d *Deps) SparkSubmitHandler(ctx context.Context, req mcp.CallToolRequest) // Even on error, result carries ExitCode/Stderr for the LLM. if result != nil { callLog.WithResult(map[string]any{ + "binary": binary, + "argv": cmd, "app_id": result.AppID, "exit_code": result.ExitCode, "duration_ms": result.DurationMS, @@ -193,6 +195,8 @@ func (d *Deps) SparkSubmitHandler(ctx context.Context, req mcp.CallToolRequest) } callLog.WithResult(map[string]any{ + "binary": binary, + "argv": cmd, "app_id": result.AppID, "exit_code": result.ExitCode, "duration_ms": result.DurationMS,