1from plain.chores import Chore, register_chore
2from plain.utils import timezone
3
4from .models import Session
5
6
7@register_chore
8class ClearExpired(Chore):
9 """Delete sessions that have expired."""
10
11 def run(self) -> str:
12 result = Session.query.filter(expires_at__lt=timezone.now()).delete()
13 return f"{result[0]} expired sessions deleted"