Method run

acouchbase/transactions/transactions.py:131–143

(self,
                  txn_logic,  # type:  Callable[[AttemptContextLogic], Coroutine[Any, Any, None]]
                  transaction_options=None,  # type: Optional[TransactionOptions]
                  **kwargs)

                         cluster.cluster_settings.default_serializer)

    async def run(self,
                  txn_logic,  # type:  Callable[[AttemptContextLogic], Coroutine[Any, Any, None]]
                  transaction_options=None,  # type: Optional[TransactionOptions]
                  **kwargs) -> TransactionResult:
        opts = None
        if transaction_options:
            opts = transaction_options._base
        if 'per_txn_config' in kwargs:
            Supportability.method_param_deprecated('per_txn_config', 'transaction_options')
            opts = kwargs.pop('per_txn_config', None)

        txn_result = await super().run_async(txn_logic, AttemptContext(self._txns, self._loop, self._transcoder, opts))
        return TransactionResult(**txn_result)

    # TODO: make async?
    def close(self):