From 9fdfaf3a7f88975dfba263916f62b0d271b7bb27 Mon Sep 17 00:00:00 2001 From: Jim Date: Tue, 15 Sep 2020 12:32:46 -0400 Subject: [PATCH] Update internal/session/repository_connection.go Co-authored-by: Jeff Mitchell --- internal/session/repository_connection.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/session/repository_connection.go b/internal/session/repository_connection.go index dd39a7f8c3..3c48805959 100644 --- a/internal/session/repository_connection.go +++ b/internal/session/repository_connection.go @@ -258,7 +258,7 @@ func (r *Repository) UpdateConnectionState(ctx context.Context, connectionId str db.StdRetryCnt, db.ExpBackoff{}, func(reader db.Reader, w db.Writer) error { - // We need to update the session version as that's the aggregate + // We need to update the connection version as that's the aggregate updatedConnection.PublicId = connectionId updatedConnection.Version = uint32(connectionVersion) + 1 rowsUpdated, err := w.Update(ctx, &updatedConnection, []string{"Version"}, nil, db.WithVersion(&connectionVersion))