(self,
fn: DatastructureCallable,
req: PycbcCoreKeyValueRequest,
obs_handler: ObservableRequestHandler,
parent_span: WrappedSpan,
create_type: Optional[bool] = None,
transcoder: Optional[Transcoder] = None)
| 874 | self._full_queue = None |
| 875 | |
| 876 | def _execute_op(self, |
| 877 | fn: DatastructureCallable, |
| 878 | req: PycbcCoreKeyValueRequest, |
| 879 | obs_handler: ObservableRequestHandler, |
| 880 | parent_span: WrappedSpan, |
| 881 | create_type: Optional[bool] = None, |
| 882 | transcoder: Optional[Transcoder] = None) -> Any: |
| 883 | try: |
| 884 | fn_args = [req] |
| 885 | if transcoder: |
| 886 | fn_args.append(transcoder) |
| 887 | fn_args.append(obs_handler) |
| 888 | return fn(*fn_args) |
| 889 | except DocumentNotFoundException as ex: |
| 890 | if create_type is True: |
| 891 | orig_opt_type = obs_handler.op_type |
| 892 | obs_handler.reset(KeyValueOperationType.Insert, exc_val=ex) |
| 893 | try: |
| 894 | ins_req = self._impl.request_builder.build_insert_request(self._key, |
| 895 | list(), |
| 896 | obs_handler, |
| 897 | parent_span=parent_span) |
| 898 | self._impl.insert(ins_req, obs_handler) |
| 899 | except DocumentExistsException: |
| 900 | pass |
| 901 | obs_handler.reset(orig_opt_type) |
| 902 | obs_handler.create_kv_span(self._impl._request_builder._collection_dtls.get_details_as_dict(), |
| 903 | parent_span=parent_span) |
| 904 | # Legacy tracing relies on passing the actual span in w/ the request. Since we are re-using the |
| 905 | # request object, we need to set the request parent span to the newly created span if we are in |
| 906 | # legacy tracing mode. |
| 907 | if obs_handler.is_legacy_tracer: |
| 908 | req.parent_span = obs_handler.legacy_request_span |
| 909 | fn_args = [req] |
| 910 | if transcoder: |
| 911 | fn_args.append(transcoder) |
| 912 | fn_args.append(obs_handler) |
| 913 | return fn(*fn_args) |
| 914 | else: |
| 915 | raise |
| 916 | |
| 917 | def _get(self, parent_span: Optional[WrappedSpan] = None) -> List: |
| 918 | """ |
no test coverage detected