diff --git a/internal/clientio/iohandler/netconn/netconn.go b/internal/clientio/iohandler/netconn/netconn.go
index 14ba9c620..02c6e957d 100644
--- a/internal/clientio/iohandler/netconn/netconn.go
+++ b/internal/clientio/iohandler/netconn/netconn.go
@@ -112,7 +112,7 @@ func (h *IOHandler) Read(ctx context.Context) ([]byte, error) {
 					// No more data to read at this time
 					return data, nil
 				case errors.Is(err, net.ErrClosed), errors.Is(err, syscall.EPIPE), errors.Is(err, syscall.ECONNRESET):
-					h.logger.Error("Connection closed", slog.Any("error", err))
+					h.logger.Debug("Connection closed", slog.Any("error", err))
 					cerr := h.Close()
 					if cerr != nil {
 						h.logger.Warn("Error closing connection", slog.Any("error", errors.Join(err, cerr)))
@@ -186,7 +186,7 @@ func (h *IOHandler) Write(ctx context.Context, response interface{}) error {
 					err = errors.Join(err, cerr)
 				}
 
-				h.logger.Error("Connection closed", slog.Any("error", err))
+				h.logger.Debug("Connection closed", slog.Any("error", err))
 				return err
 			}
 
diff --git a/internal/worker/worker.go b/internal/worker/worker.go
index 71462c406..148f59079 100644
--- a/internal/worker/worker.go
+++ b/internal/worker/worker.go
@@ -92,7 +92,7 @@ func (w *BaseWorker) Start(ctx context.Context) error {
 		case err := <-errChan:
 			if err != nil {
 				if errors.Is(err, net.ErrClosed) || errors.Is(err, syscall.EPIPE) || errors.Is(err, syscall.ECONNRESET) {
-					w.logger.Error("Connection closed for worker", slog.String("workerID", w.id), slog.Any("error", err))
+					w.logger.Debug("Connection closed for worker", slog.String("workerID", w.id), slog.Any("error", err))
 					return err
 				}
 			}