소스 검색

fix Cassandra backend TTLs

Steeve Morin 12 년 전
부모
커밋
c0640dc52f
1개의 변경된 파일2개의 추가작업 그리고 2개의 파일을 삭제
  1. 2 2
      celery/backends/cassandra.py

+ 2 - 2
celery/backends/cassandra.py

@@ -142,11 +142,11 @@ class CassandraBackend(BaseBackend):
             if self.detailed_mode:
                 meta['result'] = result
                 cf.insert(task_id, {date_done: self.encode(meta)},
-                          ttl=timedelta_seconds(self.expires))
+                          ttl=self.expires and timedelta_seconds(self.expires))
             else:
                 meta['result'] = self.encode(result)
                 cf.insert(task_id, meta,
-                          ttl=timedelta_seconds(self.expires))
+                          ttl=self.expires and timedelta_seconds(self.expires))
 
         return self._retry_on_error(_do_store)