diff --git a/django_q/monitor.py b/django_q/monitor.py index 37ea940..b6b0b43 100644 --- a/django_q/monitor.py +++ b/django_q/monitor.py @@ -145,7 +145,11 @@ def save_task(task, broker: Broker): attempt_count=1, ) - if Conf.MAX_ATTEMPTS > 0 and task_obj.attempt_count >= Conf.MAX_ATTEMPTS: + if ( + Conf.MAX_ATTEMPTS > 0 + and task_obj.attempt_count >= Conf.MAX_ATTEMPTS + and task.get("ack_id") + ): broker.acknowledge(task["ack_id"]) except Exception: