Procházet zdrojové kódy

Reject messages with invalid date values in ETA. Closes #3431

Ask Solem před 8 roky
rodič
revize
a4b29a21ca
1 změnil soubory, kde provedl 1 přidání a 1 odebrání
  1. 1 1
      celery/worker/strategy.py

+ 1 - 1
celery/worker/strategy.py

@@ -118,7 +118,7 @@ def default(task, app, consumer,
                     eta = to_timestamp(to_system_tz(req.eta))
                     eta = to_timestamp(to_system_tz(req.eta))
                 else:
                 else:
                     eta = to_timestamp(req.eta, timezone.local)
                     eta = to_timestamp(req.eta, timezone.local)
-            except OverflowError as exc:
+            except (OverflowError, ValueError) as exc:
                 error("Couldn't convert ETA %r to timestamp: %r. Task: %r",
                 error("Couldn't convert ETA %r to timestamp: %r. Task: %r",
                       req.eta, exc, req.info(safe=True), exc_info=True)
                       req.eta, exc, req.info(safe=True), exc_info=True)
                 req.reject(requeue=False)
                 req.reject(requeue=False)