FileStateStore.transaction()

Yields the locked connection inside a single committed transaction.

Usage

Source

FileStateStore.transaction()

Use this to compose consumer writes with record_file() so they commit or roll back together. record_file() called within the block joins this transaction instead of opening its own.

Yields

AsyncIterator[aiosqlite.Connection]

The store’s connection, held under the store lock.