@@ -47,17 +47,21 @@ const (
4747 ClusterRoles
4848 ClusterRoleBindings
4949
50- numHAPodsWithScheduler = 16
51- numHAPodsOld = 13
52- numNonHAPodsWithScheduler = 6
53- numNonHAPodsOld = 5
50+ numHAPodsWithScheduler = 16
51+ numHAPodsOld = 13
52+ numNonHAPodsWithHAScheduler = 8
53+ numNonHAPodsWithScheduler = 6
54+ numNonHAPodsOld = 5
5455
5556 thirdPartyDevNamespace = "default"
5657 devRedisReleaseName = "dapr-dev-redis"
5758 devZipkinReleaseName = "dapr-dev-zipkin"
5859)
5960
60- var VersionWithScheduler = semver .MustParse ("1.14.0-rc.1" )
61+ var (
62+ VersionWithScheduler = semver .MustParse ("1.14.0-rc.1" )
63+ VersionWithHAScheduler = semver .MustParse ("1.15.0-rc.1" )
64+ )
6165
6266type VersionDetails struct {
6367 RuntimeVersion string
@@ -1232,23 +1236,26 @@ func getVersionedNumberOfPods(isHAEnabled bool, details VersionDetails) (int, er
12321236 return 0 , err
12331237 }
12341238
1235- if rv .LessThan (VersionWithScheduler ) {
1236- return numHAPodsOld , nil
1239+ if rv .GreaterThanEqual (VersionWithScheduler ) {
1240+ return numHAPodsWithScheduler , nil
12371241 }
1238- return numHAPodsWithScheduler , nil
1242+ return numHAPodsOld , nil
12391243 } else {
12401244 if details .UseDaprLatestVersion {
1241- return numNonHAPodsWithScheduler , nil
1245+ return numNonHAPodsWithHAScheduler , nil
12421246 }
12431247 rv , err := semver .NewVersion (details .RuntimeVersion )
12441248 if err != nil {
12451249 return 0 , err
12461250 }
12471251
1248- if rv .LessThan (VersionWithScheduler ) {
1249- return numNonHAPodsOld , nil
1252+ if rv .GreaterThanEqual (VersionWithHAScheduler ) {
1253+ return numNonHAPodsWithHAScheduler , nil
1254+ }
1255+ if rv .GreaterThanEqual (VersionWithScheduler ) {
1256+ return numNonHAPodsWithScheduler , nil
12501257 }
1251- return numNonHAPodsWithScheduler , nil
1258+ return numNonHAPodsOld , nil
12521259 }
12531260}
12541261
0 commit comments