# update_qos()

celery · Apr 9, 2024 · 9091793 · 9091793
1 parent be0121e
commit 9091793
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)