@@ -47,14 +47,6 @@ func (s *topLevelServer) startAttemptUpgrade(ctx context.Context) error {
47
47
}
48
48
49
49
for r := retry .StartWithCtx (ctx , retryOpts ); r .Next (); {
50
- if clusterversion .AutoUpgradeSystemClusterFromMeta1Leaseholder .Get (& s .ClusterSettings ().SV ) {
51
- isMeta1LH , err := s .sqlServer .isMeta1Leaseholder (ctx , s .clock .NowAsClockTimestamp ())
52
- if err != nil || ! isMeta1LH {
53
- log .Ops .VInfof (ctx , 2 , "not upgrading since we are not the Meta1 leaseholder; err=%v" , err )
54
- continue
55
- }
56
- }
57
-
58
50
clusterVersion , err := s .clusterVersion (ctx )
59
51
if err != nil {
60
52
log .Dev .Errorf (ctx , "unable to retrieve cluster version: %v" , err )
@@ -94,6 +86,14 @@ func (s *topLevelServer) startAttemptUpgrade(ctx context.Context) error {
94
86
panic (errors .AssertionFailedf ("unhandled case: %d" , status ))
95
87
}
96
88
89
+ if clusterversion .AutoUpgradeSystemClusterFromMeta1Leaseholder .Get (& s .ClusterSettings ().SV ) {
90
+ isMeta1LH , err := s .sqlServer .isMeta1Leaseholder (ctx , s .clock .NowAsClockTimestamp ())
91
+ if err != nil || ! isMeta1LH {
92
+ log .Ops .VInfof (ctx , 2 , "not upgrading since we are not the Meta1 leaseholder; err=%v" , err )
93
+ continue
94
+ }
95
+ }
96
+
97
97
upgradeRetryOpts := retry.Options {
98
98
InitialBackoff : 5 * time .Second ,
99
99
MaxBackoff : 10 * time .Second ,
0 commit comments