| 72 | return self._impl.name |
| 73 | |
| 74 | def get(self, |
| 75 | key, # type: str |
| 76 | *opts, # type: GetOptions |
| 77 | **kwargs, # type: Dict[str, Any] |
| 78 | ) -> Deferred[GetResult]: |
| 79 | instruments = self._impl.observability_instruments |
| 80 | obs_handler = ObservableRequestHandler.create_or_none(KeyValueOperationType.Get, instruments) |
| 81 | try: |
| 82 | req, transcoder = self._impl.request_builder.build_get_request(key, obs_handler, *opts, **kwargs) |
| 83 | d = self._impl.get_deferred(req, transcoder, obs_handler) |
| 84 | d.addBoth(self._impl._finish_span, obs_handler) |
| 85 | return d |
| 86 | except Exception as e: |
| 87 | if obs_handler is not None: |
| 88 | obs_handler.__exit__(type(e), e, e.__traceback__) |
| 89 | raise |
| 90 | |
| 91 | def get_any_replica(self, |
| 92 | key, # type: str |