diff --git a/internal/state/completion.go b/internal/state/completion.go
index 3afdcc6..48daa47 100644
--- a/internal/state/completion.go
+++ b/internal/state/completion.go
@@ -2,14 +2,11 @@ package state
 
 import (
 	"context"
-	"errors"
 	"fmt"
-	"io"
 	"sync"
 
 	"github.com/restatedev/sdk-go/generated/proto/protocol"
 	"github.com/restatedev/sdk-go/internal/wire"
-	"golang.org/x/net/http2"
 	"google.golang.org/protobuf/proto"
 )
 
@@ -151,15 +148,6 @@ func (m *Machine) handleCompletionsAcks() {
 	for {
 		msg, err := m.protocol.Read()
 		if err != nil {
-			if errors.Is(err, io.EOF) {
-				return
-			}
-			var t *http2.StreamError
-			if errors.As(err, &t) && t.Code == http2.ErrCodeNo {
-				// normal close
-				return
-			}
-			m.log.Error().Err(err).Msg("issue reading completions & acks")
 			return
 		}
 		switch msg.Type() {