Update error logging

Signed-off-by: Maksym Pavlenko <pavlenko.maksym@gmail.com>

cmd/containerd-shim-runc-v2/task/service.go

@@ -24,15 +24,20 @@ import (
 	"os"
 	"sync"
 
-	"github.com/containerd/containerd/v2/api/types"
+	"github.com/containerd/cgroups/v3"
+	"github.com/containerd/cgroups/v3/cgroup1"
+	"github.com/containerd/errdefs"
+	runcC "github.com/containerd/go-runc"
+	"github.com/containerd/log"
+	"github.com/containerd/ttrpc"
+	"github.com/containerd/typeurl/v2"
 	"google.golang.org/protobuf/types/known/emptypb"
 	"google.golang.org/protobuf/types/known/timestamppb"
 
-	"github.com/containerd/cgroups/v3"
-	"github.com/containerd/cgroups/v3/cgroup1"
 	cgroupsv2 "github.com/containerd/cgroups/v3/cgroup2"
 	eventstypes "github.com/containerd/containerd/v2/api/events"
 	taskAPI "github.com/containerd/containerd/v2/api/runtime/task/v3"
+	"github.com/containerd/containerd/v2/api/types"
 	"github.com/containerd/containerd/v2/api/types/task"
 	"github.com/containerd/containerd/v2/cmd/containerd-shim-runc-v2/process"
 	"github.com/containerd/containerd/v2/cmd/containerd-shim-runc-v2/runc"
@@ -49,11 +54,6 @@ import (
 	"github.com/containerd/containerd/v2/pkg/userns"
 	"github.com/containerd/containerd/v2/protobuf"
 	ptypes "github.com/containerd/containerd/v2/protobuf/types"
-	"github.com/containerd/errdefs"
-	runcC "github.com/containerd/go-runc"
-	"github.com/containerd/log"
-	"github.com/containerd/ttrpc"
-	"github.com/containerd/typeurl/v2"
 )
 
 var (

core/runtime/v2/manager.go

@@ -21,6 +21,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"io"
 	"os"
 	"os/exec"
 	"path/filepath"
@@ -528,7 +529,7 @@ func (m *TaskManager) tryStreamEvents(ctx context.Context, shim *shimTask) error
 		return nil
 	}
 
-	log.G(ctx).Info("using shim events streaming")
+	log.G(ctx).Debugf("using shim events streaming for task %s", shim.ID())
 
 	stream, err := shim.task.Events(context.Background(), nil)
 	if err != nil {
@@ -539,7 +540,10 @@ func (m *TaskManager) tryStreamEvents(ctx context.Context, shim *shimTask) error
 		for {
 			evt, err := stream.Recv()
 			if err != nil {
-				log.G(ctx).WithError(err).Error("failed to receive shim event from stream")
+				if !errors.Is(err, io.EOF) {
+					log.G(ctx).WithError(err).Error("failed to receive shim event from stream")
+				}
+
 				break
 			}