diff options
| author | Mike Bayer <mike_mp@zzzcomputing.com> | 2012-06-25 11:15:50 -0400 |
|---|---|---|
| committer | Mike Bayer <mike_mp@zzzcomputing.com> | 2012-06-25 11:15:50 -0400 |
| commit | 7b1a1a66cd36fdfac6541e6b771fd6c849b0bd7d (patch) | |
| tree | 7e69db65936305fc9817f6e2ff4652078ce49510 /lib/sqlalchemy/util/queue.py | |
| parent | c5f824100631b7d95727984c4ceab65b4255f7b5 (diff) | |
| download | sqlalchemy-7b1a1a66cd36fdfac6541e6b771fd6c849b0bd7d.tar.gz | |
- change notify to notify_all() so all waiters exit immediately,
continuing [ticket:2522]
Diffstat (limited to 'lib/sqlalchemy/util/queue.py')
| -rw-r--r-- | lib/sqlalchemy/util/queue.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/lib/sqlalchemy/util/queue.py b/lib/sqlalchemy/util/queue.py index ebf736331..9e17527b7 100644 --- a/lib/sqlalchemy/util/queue.py +++ b/lib/sqlalchemy/util/queue.py @@ -183,7 +183,7 @@ class Queue: if not self.not_full.acquire(False): return try: - self.not_empty.notify() + self.not_empty.notify_all() finally: self.not_full.release() |