diff options
| author | Steven <stevenjose@gmail.com> | 2021-08-26 23:16:24 +1000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-08-26 19:16:24 +0600 |
| commit | cad7a88b3f189f84a81e641abd5689eafc2286fd (patch) | |
| tree | 21c720a0ab0641a18fd73a6aa77f3742f5ef1806 | |
| parent | 39584a194055bc42f4836a5213eb0be141001500 (diff) | |
| download | kombu-cad7a88b3f189f84a81e641abd5689eafc2286fd.tar.gz | |
fix: raise BrokenPipeError (#1231)
Co-authored-by: Steven Joseph <steven@pointzi.com>
Co-authored-by: Steven Joseph <steven@stevenjoseph.in>
| -rw-r--r-- | kombu/message.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/kombu/message.py b/kombu/message.py index a4d7e2d4..bcc90d1a 100644 --- a/kombu/message.py +++ b/kombu/message.py @@ -126,6 +126,10 @@ class Message: def ack_log_error(self, logger, errors, multiple=False): try: self.ack(multiple=multiple) + except BrokenPipeError as exc: + logger.critical("Couldn't ack %r, reason:%r", + self.delivery_tag, exc, exc_info=True) + raise except errors as exc: logger.critical("Couldn't ack %r, reason:%r", self.delivery_tag, exc, exc_info=True) |