diff --git a/internal/executor/sandbox/executor.go b/internal/executor/sandbox/executor.go index 7a3a63f..746717b 100644 --- a/internal/executor/sandbox/executor.go +++ b/internal/executor/sandbox/executor.go @@ -59,7 +59,7 @@ func (e *Sandbox) Run(cmds []stage.Cmd) ([]stage.ExecutorResult, error) { ) } } - slog.Debug("sandbox execute", "total protobuf cmd size", totalPbCmdSize) + slog.Info("sandbox execute", "total protobuf cmd size", totalPbCmdSize) pbReq := &pb.Request{Cmd: pbCmds} pbRet, err := e.execClient.Exec(context.TODO(), pbReq) if err != nil { diff --git a/internal/executor/sandbox/grpc.go b/internal/executor/sandbox/grpc.go index 6bb75c3..09ac7ef 100644 --- a/internal/executor/sandbox/grpc.go +++ b/internal/executor/sandbox/grpc.go @@ -23,6 +23,9 @@ func createExecClient(execServer, token string) (pb.ExecutorClient, error) { func createGRPCConnection(addr, token string) (*grpc.ClientConn, error) { opts := []grpc.DialOption{ grpc.WithTransportCredentials(insecure.NewCredentials()), + grpc.WithDefaultCallOptions( + grpc.MaxCallRecvMsgSize(512 * 1024 * 1024), // 512 MB + ), } if token != "" { opts = append(opts, grpc.WithPerRPCCredentials(newTokenAuth(token)))