Clears the queue.
(self)
| 1043 | return sd_res.value[0].get('value', None) |
| 1044 | |
| 1045 | def clear(self) -> None: |
| 1046 | """Clears the queue. |
| 1047 | """ |
| 1048 | op_type = DatastructureOperationType.QueueClear |
| 1049 | with ObservableRequestHandler(op_type, self._impl.observability_instruments) as ds_obs_handler: |
| 1050 | ds_obs_handler.create_kv_span(self._impl._request_builder._collection_dtls.get_details_as_dict()) |
| 1051 | kv_op_type = KeyValueOperationType.Remove |
| 1052 | with ObservableRequestHandler(kv_op_type, self._impl.observability_instruments) as obs_handler: |
| 1053 | try: |
| 1054 | req = self._impl.request_builder.build_remove_request(self._key, |
| 1055 | obs_handler, |
| 1056 | parent_span=ds_obs_handler.wrapped_span) |
| 1057 | self._impl.remove(req, obs_handler) |
| 1058 | except DocumentNotFoundException: |
| 1059 | pass |
| 1060 | |
| 1061 | def __iter__(self): |
| 1062 | list_ = self._get() |
nothing calls this directly
no test coverage detected