diff options
Diffstat (limited to 'lib/sqlalchemy/util/queue.py')
| -rw-r--r-- | lib/sqlalchemy/util/queue.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/lib/sqlalchemy/util/queue.py b/lib/sqlalchemy/util/queue.py index f7b35924c..26d335623 100644 --- a/lib/sqlalchemy/util/queue.py +++ b/lib/sqlalchemy/util/queue.py @@ -42,16 +42,19 @@ class Empty(Exception): pass + class Full(Exception): "Exception raised by Queue.put(block=0)/put_nowait()." pass + class SAAbort(Exception): "Special SQLA exception to abort waiting" def __init__(self, context): self.context = context + class Queue: def __init__(self, maxsize=0): """Initialize a queue object with a given maximum size. |