Explorar el Código

Reject, not ack, messageswith invalid ETA value (Issue #3431)

Ask Solem hace 8 años
padre
commit
24f7b9462e
Se han modificado 1 ficheros con 1 adiciones y 1 borrados
  1. 1 1
      celery/worker/strategy.py

+ 1 - 1
celery/worker/strategy.py

@@ -121,7 +121,7 @@ def default(task, app, consumer,
             except OverflowError as exc:
                 error("Couldn't convert ETA %r to timestamp: %r. Task: %r",
                       req.eta, exc, req.info(safe=True), exc_info=True)
-                req.acknowledge()
+                req.reject(requeue=False)
             else:
                 consumer.qos.increment_eventually()
                 call_at(eta, apply_eta_task, (req,), priority=6)