| 1032 | self._redis.hdel(self._name, redis_key) |
| 1033 | |
| 1034 | def insert(self, key, *vals, **kwargs): |
| 1035 | # Using buffer=True outside of an `insertion_session` |
| 1036 | # could lead to inconsistencies, because those |
| 1037 | # insertion will not be processed until the |
| 1038 | # buffer is cleared |
| 1039 | buffer = kwargs.pop('buffer', False) |
| 1040 | if buffer: |
| 1041 | self._insert(self._buffer, key, *vals) |
| 1042 | else: |
| 1043 | self._insert(self._redis, key, *vals) |
| 1044 | |
| 1045 | def _insert(self, r, key, *values): |
| 1046 | redis_key = self.redis_key(key) |