Provides extra context to the exception prior to it being handled
(self, exception, number, command)
| 2509 | return self._pipe |
| 2510 | |
| 2511 | def _annotate_exception(self, exception, number, command): |
| 2512 | """ |
| 2513 | Provides extra context to the exception prior to it being handled |
| 2514 | """ |
| 2515 | cmd = " ".join(map(safe_str, command)) |
| 2516 | msg = ( |
| 2517 | f"Command # {number} ({truncate_text(cmd)}) of pipeline " |
| 2518 | f"caused error: {exception.args[0]}" |
| 2519 | ) |
| 2520 | exception.args = (msg,) + exception.args[1:] |
| 2521 | |
| 2522 | @abstractmethod |
| 2523 | def mset_nonatomic( |
no test coverage detected