(self, key)
| 99 | blob.upload_from_string(value, retry=self._retry_policy) |
| 100 | |
| 101 | def delete(self, key): |
| 102 | key = bytes_to_str(key) |
| 103 | blob = self._get_blob(key) |
| 104 | if blob.exists(): |
| 105 | blob.delete(retry=self._retry_policy) |
| 106 | |
| 107 | def mget(self, keys): |
| 108 | with ThreadPoolExecutor() as pool: |
no test coverage detected