Transaction management

[ahopkins]

executor = SomeExecutor()

async with executor.transaction() as transaction:
    try:
        await executor.do_something()
    except Exception:
        await transaction.rollback()