(self, keys)
| 106 | return value |
| 107 | |
| 108 | async def amget(self, keys): |
| 109 | if not keys: |
| 110 | return {} |
| 111 | |
| 112 | prefixed_keys_map = {self.add_prefix(key): key for key in keys} |
| 113 | results = {} |
| 114 | |
| 115 | if self._cache: |
| 116 | cache_results = await self._cache.aget_many(prefixed_keys_map.keys()) |
| 117 | for prefixed_key, value in cache_results.items(): |
| 118 | results[prefixed_keys_map[prefixed_key]] = value |
| 119 | |
| 120 | missing_prefixed_keys = [k for k in prefixed_keys_map if prefixed_keys_map[k] not in results] |
| 121 | if missing_prefixed_keys: |
| 122 | try: |
| 123 | async for const in self._model._default_manager.filter(key__in=missing_prefixed_keys): |
| 124 | results[prefixed_keys_map[const.key]] = loads(const.value) |
| 125 | except (OperationalError, ProgrammingError): |
| 126 | pass |
| 127 | |
| 128 | return results |
| 129 | |
| 130 | def set(self, key, value): |
| 131 | key = self.add_prefix(key) |
nothing calls this directly
no test coverage detected