소스 검색

Tests passing

Ask Solem 11 년 전
부모
커밋
37f8b2b3bd
1개의 변경된 파일5개의 추가작업 그리고 1개의 파일을 삭제
  1. 5 1
      celery/tests/events/test_state.py

+ 5 - 1
celery/tests/events/test_state.py

@@ -34,7 +34,10 @@ class replay(object):
     def next_event(self):
     def next_event(self):
         ev = self.events[next(self.position)]
         ev = self.events[next(self.position)]
         ev['local_received'] = ev['timestamp']
         ev['local_received'] = ev['timestamp']
-        self.current_clock = ev.get('clock') or self.current_clock + 1
+        try:
+            self.current_clock = ev['clock']
+        except KeyError:
+            ev['clock'] = self.current_clock = self.current_clock + 1
         return ev
         return ev
 
 
     def __iter__(self):
     def __iter__(self):
@@ -474,6 +477,7 @@ class test_State(AppCase):
                 'hostname': 'y',
                 'hostname': 'y',
                 'timestamp': time(),
                 'timestamp': time(),
                 'local_received': time(),
                 'local_received': time(),
+                'clock': 0,
             },
             },
         )
         )