

@utils.decorator
def transactional_async(func, args, kwds, **options):
    'The async version of @ndb.transaction.'
    options.setdefault('propagation', datastore_rpc.TransactionOptions.ALLOWED)
    if (args or kwds):
        return transaction_async((lambda : func(*args, **kwds)), **kwds)
    return transaction_async(func, **options)

dataset/ETHPy150Open GoogleCloudPlatform/datastore-ndb-python/ndb/model.py transactional_async/VarMisuse@63/88 `options`->`kwds`