소스 검색

Add is_done=True to get_all_expired filter.

Ask Solem 16 년 전
부모
커밋
52ffc2b264
1개의 변경된 파일2개의 추가작업 그리고 1개의 파일을 삭제
  1. 2 1
      celery/managers.py

+ 2 - 1
celery/managers.py

@@ -15,7 +15,8 @@ class TaskManager(models.Manager):
         return self.get_task(task_id).is_done
 
     def get_all_expired(self):
-        return self.filter(date_done__lt=datetime.now() - timedelta(days=5))
+        return self.filter(date_done__lt=datetime.now() - timedelta(days=5),
+                           is_done=True)
 
     def delete_expired(self):
         self.get_all_expired().delete()