Revert "# update_qos()"

This reverts commit 9091793.
celery · Apr 14, 2024 · 87ef528 · 87ef528
1 parent bd67386
commit 87ef528
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/celery/worker/loops.py b/celery/worker/loops.py
@@ -90,8 +90,8 @@ def asynloop(obj, connection, consumer, blueprint, hub, qos,
             # We only update QoS when there's no more messages to read.
             # This groups together qos calls, and makes sure that remote
             # control commands will be prioritized over task messages.
-            # if qos.prev != qos.value:
-            #     update_qos()
+            if qos.prev != qos.value:
+                update_qos()
 
             try:
                 next(loop)