Start and stop job groups in correct order

fluxninja · Jan 23, 2024 · 25748d7 · 25748d7
1 parent 8bf3b05
commit 25748d7
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/api/buf.lock b/api/buf.lock
@@ -9,8 +9,8 @@ deps:
   - remote: buf.build
     owner: envoyproxy
     repository: envoy
-    commit: 9459cee0da6c4851910210470bf29707
-    digest: shake256:57e84ac601767357c23e2d0883a50c0e4910eb4488ed2897552e588a96c566b0390802ca4fe4609efe77d12bb9159e2b10702dd03d9bdbfc831e86a26af5f6ec
+    commit: 9dfb7a90eac7464ca2545f761710b266
+    digest: shake256:3c1866bae7fd11a858aa117ef44fe917688ae3c8d21b41bcffd717d5b5f2629ec7ec5d4814e6386ebf95e5f96772c7326b5373803190042a14b494cc1a1b14bb
   - remote: buf.build
     owner: envoyproxy
     repository: protoc-gen-validate

diff --git a/pkg/policies/flowcontrol/actuators/quota-scheduler/quota-scheduler.go b/pkg/policies/flowcontrol/actuators/quota-scheduler/quota-scheduler.go
@@ -158,11 +158,11 @@ func setupQuotaSchedulerFactory(
 			if err != nil {
 				merr = multierr.Append(merr, err)
 			}
-			err = auditJobGroup.Stop()
+			err = rateLimiterJobGroup.Stop()
 			if err != nil {
 				merr = multierr.Append(merr, err)
 			}
-			err = rateLimiterJobGroup.Stop()
+			err = auditJobGroup.Stop()
 			if err != nil {
 				merr = multierr.Append(merr, err)
 			}

diff --git a/pkg/policies/flowcontrol/actuators/rate-limiter/rate-limiter.go b/pkg/policies/flowcontrol/actuators/rate-limiter/rate-limiter.go
@@ -170,11 +170,11 @@ func setupRateLimiterFactory(
 			if err != nil {
 				merr = multierr.Append(merr, err)
 			}
-			err = lazySyncJobGroup.Stop()
+			err = rateLimiterJobGroup.Stop()
 			if err != nil {
 				merr = multierr.Append(merr, err)
 			}
-			err = rateLimiterJobGroup.Stop()
+			err = lazySyncJobGroup.Stop()
 			if err != nil {
 				merr = multierr.Append(merr, err)
 			}