fix it there too.

This commit is contained in:
Greg Banks
2014-02-04 09:44:01 -08:00
parent 66d1c324a9
commit 5a420f3967

View File

@@ -182,14 +182,14 @@ flight at any time:
from itertools import count
from threading import Event
sentinal = object()
sentinel = object()
num_queries = 100000
num_started = count()
num_finished = count()
finished_event = Event()
def insert_next(previous_result=sentinal):
if previous_result is not sentinal:
def insert_next(previous_result=sentinel):
if previous_result is not sentinel:
if isinstance(previous_result, BaseException):
log.error("Error on insert: %r", previous_result)
if num_finished.next() >= num_queries: