소스 검색

Events: Workers were not recognized as alive, because max_heartbets removed new heartbeats instead of old

Ask Solem 14 년 전
부모
커밋
eb6f52ca1b
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      celery/events/state.py

+ 1 - 1
celery/events/state.py

@@ -41,7 +41,7 @@ class Worker(Element):
         if timestamp:
         if timestamp:
             heapq.heappush(self.heartbeats, timestamp)
             heapq.heappush(self.heartbeats, timestamp)
             if len(self.heartbeats) > self.heartbeat_max:
             if len(self.heartbeats) > self.heartbeat_max:
-                self.heartbeats = self.heartbeats[:self.heartbeat_max]
+                self.heartbeats = self.heartbeats[self.heartbeat_max:]
 
 
     def __repr__(self):
     def __repr__(self):
         return "<Worker: %s (%s)" % (self.hostname,
         return "<Worker: %s (%s)" % (self.hostname,