From 87ef5283be8aadad7fce558bf8d9f932575e6731 Mon Sep 17 00:00:00 2001 From: Tomer Nosrati Date: Thu, 11 Apr 2024 18:54:14 +0300 Subject: [PATCH] Revert "# update_qos()" This reverts commit 9091793319ec445a49b2ed59fb97d2e75845b92a. --- celery/worker/loops.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/celery/worker/loops.py b/celery/worker/loops.py index c64e52dd428..0630e679fdd 100644 --- 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)