(self, connection, command_name, **options)
| 1980 | exception.args = (msg,) + exception.args[1:] |
| 1981 | |
| 1982 | def parse_response(self, connection, command_name, **options): |
| 1983 | result = Redis.parse_response(self, connection, command_name, **options) |
| 1984 | if command_name in self.UNWATCH_COMMANDS: |
| 1985 | self.watching = False |
| 1986 | elif command_name == "WATCH": |
| 1987 | self.watching = True |
| 1988 | return result |
| 1989 | |
| 1990 | def load_scripts(self): |
| 1991 | # make sure all scripts that are about to be run on this pipeline exist |
no test coverage detected