Browse Source

fix Cassandra backend TTLs

Steeve Morin 12 years ago
parent
commit
402fd2e192
1 changed files with 2 additions and 2 deletions
  1. 2 2
      celery/backends/cassandra.py

+ 2 - 2
celery/backends/cassandra.py

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