Merge pull request #7 from PatrickTaibel/ptaibel/SIANXSVC-1060_timeou…

…t_clear_queue SIANXSVC-1060: Fix queues not cleaned up after an `AMQPWaitTimeoutException`
anexia · Nov 3, 2023 · acd43c3 · acd43c3
2 parents 0762340 + 36cd2d1
commit acd43c3
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/celery_amqp_backend/exceptions.py b/celery_amqp_backend/exceptions.py
@@ -1,3 +1,5 @@
+import celery.exceptions
+
 __all__ = [
     'AMQPBacklogLimitExceededException',
     'AMQPWaitEmptyException',
@@ -25,5 +27,5 @@ class AMQPWaitEmptyException(BaseCeleryException):
     _msg_template = 'No message got drained from the queue while waiting for "{task}".'
 
 
-class AMQPWaitTimeoutException(BaseCeleryException, TimeoutError):
+class AMQPWaitTimeoutException(BaseCeleryException, celery.exceptions.TimeoutError):
     _msg_template = 'The operation timed out.'