| 76 | raise |
| 77 | |
| 78 | def append( |
| 79 | self, |
| 80 | key, # type: str |
| 81 | value, # type: Union[str,bytes,bytearray] |
| 82 | *opts, # type: AppendOptions |
| 83 | **kwargs, # type: Any |
| 84 | ) -> Deferred[MutationResult]: |
| 85 | instruments = self._impl.observability_instruments |
| 86 | obs_handler = ObservableRequestHandler.create_or_none(KeyValueOperationType.Append, instruments) |
| 87 | try: |
| 88 | req = self._impl.request_builder.build_append_request(key, value, obs_handler, *opts, **kwargs) |
| 89 | d = self._impl.append_deferred(req, obs_handler) |
| 90 | d.addBoth(self._impl._finish_span, obs_handler) |
| 91 | return d |
| 92 | except Exception as e: |
| 93 | if obs_handler is not None: |
| 94 | obs_handler.__exit__(type(e), e, e.__traceback__) |
| 95 | raise |
| 96 | |
| 97 | def prepend( |
| 98 | self, |