‘AsyncSession’ object has no attribute ‘query’

Error in SQLAlchemy: ‘AsyncSession’ object has no attribute ‘query’.

What happened

SQLAlchemy updated the syntax from a certain version.

Instead of db.query(Task) now you need to use db.execute(select(Task))


Previously worked:

async def fetch_all(db: Session, skip: int = 0, limit: int = 20):
return db.query(Task).order_by(Task.time.desc()).offset(skip).limit(limit).all()

Now it needs to work:

async def fetch_all(db: AsyncSession, skip: int = 0, limit: int = 20):
result = await db.execute(select(Task).order_by(Task.time.desc()).limit(20))
return result.scalars().all()

Similar Posts

Leave a Reply

Your email address will not be published. Required fields are marked *