We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 20d6e97 commit 09b2ed8Copy full SHA for 09b2ed8
celery/backends/database.py
@@ -87,12 +87,10 @@ def cleanup(self):
87
session = self.ResultSession()
88
expires = self.result_expires
89
try:
90
- qs = session.query(Task).filter(
91
- Task.date_done < (datetime.now() - expires)):
92
- qs.delete()
93
- qs = session.query(TaskSet).filter(
94
- TaskSet.date_done < (datetime.now() - expires)):
95
- qs = session.delete()
+ session.query(Task).filter(
+ Task.date_done < (datetime.now() - expires)).delete()
+ session.query(TaskSet).filter(
+ TaskSet.date_done < (datetime.now() - expires)).delete()
96
session.commit()
97
finally:
98
session.close()
0 commit comments