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