(
self, exception: Exception, number: int, command: Iterable[object]
)
| 1970 | raise r |
| 1971 | |
| 1972 | def annotate_exception( |
| 1973 | self, exception: Exception, number: int, command: Iterable[object] |
| 1974 | ) -> None: |
| 1975 | cmd = " ".join(map(safe_str, command)) |
| 1976 | msg = ( |
| 1977 | f"Command # {number} ({truncate_text(cmd)}) " |
| 1978 | f"of pipeline caused error: {exception.args}" |
| 1979 | ) |
| 1980 | exception.args = (msg,) + exception.args[1:] |
| 1981 | |
| 1982 | async def parse_response( |
| 1983 | self, connection: Connection, command_name: Union[str, bytes], **options |
no test coverage detected