Code: Select all
@app.on_event('startup')
@repeat_every(seconds=300)
async def delete_expired_otp(db: db_dependency):
print("deleting")
expired_otp = db.query(OTPModel).filter(OTPModel.expires_at < datetime.utcnow()).all()
if expired_otp:
for otp in expired_otp:
db.delete(otp)
db.commit()
print("deleted")