Преглед на файлове

timer .enter now supports timestamps instead of datetimes

Ask Solem преди 13 години
родител
ревизия
8ccfa2912e
променени са 1 файла, в които са добавени 7 реда и са изтрити 6 реда
  1. 7 6
      celery/utils/timer2.py

+ 7 - 6
celery/utils/timer2.py

@@ -115,12 +115,13 @@ class Schedule(object):
         """
         if eta is None:
             eta = datetime.now()
-        try:
-            eta = to_timestamp(eta)
-        except OverflowError, exc:
-            if not self.handle_error(exc):
-                raise
-            return
+        if isinstance(eta, datetime):
+            try:
+                eta = to_timestamp(eta)
+            except OverflowError, exc:
+                if not self.handle_error(exc):
+                    raise
+                return
         return self._enter(eta, priority, entry)
 
     def _enter(self, eta, priority, entry):