feat(executor): only log pbCmd & pbReq size
This commit is contained in:
		
							parent
							
								
									153c261ab8
								
							
						
					
					
						commit
						58b69523aa
					
				|  | @ -38,29 +38,11 @@ func (e *Sandbox) Run(cmds []stage.Cmd) ([]stage.ExecutorResult, error) { | ||||||
| 		} | 		} | ||||||
| 	} | 	} | ||||||
| 	pbCmds := convertPBCmd(cmds) | 	pbCmds := convertPBCmd(cmds) | ||||||
| 	totalPbCmdSize := 0 |  | ||||||
| 	for i, pbCmd := range pbCmds { | 	for i, pbCmd := range pbCmds { | ||||||
| 		pbCmdSize := proto.Size(pbCmd) | 		slog.Debug("sandbox execute", "i", i, "pbCmd size", proto.Size(pbCmd)) | ||||||
| 		totalPbCmdSize += pbCmdSize |  | ||||||
| 		slog.Debug( |  | ||||||
| 			"sandbox execute", |  | ||||||
| 			"index", i, |  | ||||||
| 			"protobuf cmd size", pbCmdSize, |  | ||||||
| 			"protobuf cmd stdin size", proto.Size(pbCmd.Files[0]), |  | ||||||
| 			"protobuf cmd stdout size", proto.Size(pbCmd.Files[1]), |  | ||||||
| 			"protobuf cmd stderr size", proto.Size(pbCmd.Files[2]), |  | ||||||
| 		) |  | ||||||
| 		for k, v := range pbCmd.CopyIn { |  | ||||||
| 			slog.Debug( |  | ||||||
| 				"sandbox execute", |  | ||||||
| 				"index", i, |  | ||||||
| 				"CopyIn filename", k, |  | ||||||
| 				"protobuf file size", proto.Size(v), |  | ||||||
| 			) |  | ||||||
| 	} | 	} | ||||||
| 	} |  | ||||||
| 	slog.Info("sandbox execute", "total protobuf cmd size", totalPbCmdSize) |  | ||||||
| 	pbReq := &pb.Request{Cmd: pbCmds} | 	pbReq := &pb.Request{Cmd: pbCmds} | ||||||
|  | 	slog.Info("sandbox execute", "pbReq size", proto.Size(pbReq)) | ||||||
| 	pbRet, err := e.execClient.Exec(context.TODO(), pbReq) | 	pbRet, err := e.execClient.Exec(context.TODO(), pbReq) | ||||||
| 	if err != nil { | 	if err != nil { | ||||||
| 		return nil, err | 		return nil, err | ||||||
|  |  | ||||||
		Loading…
	
		Reference in New Issue
	
	Block a user