Method _execute_op

acouchbase/datastructures.py:655–696

(self,
                          fn: DatastructureCallable,
                          req: PycbcCoreKeyValueRequest,
                          obs_handler: ObservableRequestHandler,
                          parent_span: WrappedSpan,
                          create_type: Optional[bool] = None,
                          transcoder: Optional[Transcoder] = None)

        self._impl = collection_impl

    async def _execute_op(self,
                          fn: DatastructureCallable,
                          req: PycbcCoreKeyValueRequest,
                          obs_handler: ObservableRequestHandler,
                          parent_span: WrappedSpan,
                          create_type: Optional[bool] = None,
                          transcoder: Optional[Transcoder] = None) -> Any:
        try:
            fn_args = [req]
            if transcoder:
                fn_args.append(transcoder)
            fn_args.append(obs_handler)
            return await fn(*fn_args)
        except DocumentNotFoundException as ex:
            if create_type is True:
                orig_opt_type = obs_handler.op_type
                obs_handler.reset(KeyValueOperationType.Insert, exc_val=ex)
                try:
                    ins_req = self._impl.request_builder.build_insert_request(self._key,
                                                                              list(),
                                                                              obs_handler,
                                                                              parent_span=parent_span)
                    await self._impl.insert(ins_req, obs_handler)
                except DocumentExistsException:
                    pass
                obs_handler.reset(orig_opt_type)
                obs_handler.create_kv_span(self._impl._request_builder._collection_dtls.get_details_as_dict(),
                                           parent_span=parent_span)

                # Legacy tracing relies on passing the actual span in w/ the request. Since we are re-using the
                # request object, we need to set the request parent span to the newly created span if we are in
                # legacy tracing mode.
                if obs_handler.is_legacy_tracer:
                    req.parent_span = obs_handler.legacy_request_span

                fn_args = [req]
                if transcoder:
                    fn_args.append(transcoder)
                fn_args.append(obs_handler)
                return await fn(*fn_args)
            else:
                raise

    async def _get(self, parent_span: Optional[WrappedSpan] = None) -> List:
        """