AttributeError: 'AsyncIOMotorClientSession' object has no attribute '_txn_read_preference'

import asyncio
import motor.motor_asyncio

async def main():
	client = motor.motor_asyncio.AsyncIOMotorClient()
	async with await client.start_session() as s:
		async with client.db.collection.watch(session=s) as change_stream:
			async for change in change_stream:
				print(change)

asyncio.run(main())