Parcourir la source

Call task_done on exception

Gabriel Adrian Samfira il y a 4 ans
Parent
commit
e74e1a7b35
1 fichiers modifiés avec 2 ajouts et 0 suppressions
  1. 2 0
      coriolis/providers/backup_writers.py

+ 2 - 0
coriolis/providers/backup_writers.py

@@ -635,6 +635,7 @@ class HTTPBackupWriterImpl(BaseBackupWriterImpl):
                 except Exception as err:
                 except Exception as err:
                     LOG.exception(err)
                     LOG.exception(err)
                     self._exception = err
                     self._exception = err
+                    self._comp_q.task_done()
                     raise
                     raise
             send_payload["chunk"] = chunk
             send_payload["chunk"] = chunk
             self._sender_q.put(send_payload)
             self._sender_q.put(send_payload)
@@ -676,6 +677,7 @@ class HTTPBackupWriterImpl(BaseBackupWriterImpl):
                 # the writer if this is set
                 # the writer if this is set
                 LOG.exception(err)
                 LOG.exception(err)
                 self._exception = err
                 self._exception = err
+                self._sender_q.task_done()
                 raise
                 raise
             self._sender_q.task_done()
             self._sender_q.task_done()