diff --git a/pkg/networkservice/common/begin/server.go b/pkg/networkservice/common/begin/server.go
index 295b71af7..54ff78c56 100644
--- a/pkg/networkservice/common/begin/server.go
+++ b/pkg/networkservice/common/begin/server.go
@@ -72,6 +72,7 @@ func (b *beginServer) Request(ctx context.Context, request *networkservice.Netwo
 				if closeErr != nil {
 					log.FromContext(ctx).Errorf("Can't close old connection: %v", closeErr)
 				}
+				eventFactoryServer.state = closed
 			}
 		}
 		conn, err = next.Server(withEventFactoryCtx).Request(withEventFactoryCtx, request)