support CloseSession

slackhq · Nov 3, 2023 · 532dccc · 532dccc
1 parent 10521db
commit 532dccc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/go/vt/vtgateproxy/vtgateproxy.go b/go/vt/vtgateproxy/vtgateproxy.go
@@ -104,7 +104,7 @@ func (proxy *VTGateProxy) NewSession(ctx context.Context, options *querypb.Execu
 // same effect as if a "rollback" statement was executed, but does not affect the query
 // statistics.
 func (proxy *VTGateProxy) CloseSession(ctx context.Context, session *vtgateconn.VTGateSession) error {
-	return vterrors.Errorf(vtrpcpb.Code_UNIMPLEMENTED, "not implemented")
+	return session.CloseSession(ctx)
 }
 
 // ResolveTransaction resolves the specified 2PC transaction.