Update search_queue.py

This commit is contained in:
krazykrazz 2014-05-08 20:18:37 -04:00
parent 0b81e63bba
commit 5e95c5bc02
1 changed files with 2 additions and 2 deletions

View File

@ -142,7 +142,7 @@ class SearchQueue(generic_queue.GenericQueue):
return self.min_priority >= generic_queue.QueuePriorities.NORMAL
def is_backlog_in_progress(self):
for cur_item in self.queue + [self.currentItem]:
for cur_item in self.queue.queue + [self.currentItem]:
if isinstance(cur_item, BacklogQueueItem):
return True
return False
@ -441,4 +441,4 @@ class FailedQueueItem(generic_queue.QueueItem):
def snatch_results(f):
for result in f.result():
snatch_queue_item = SnatchQueueItem(result, result.queue_item)
SnatchQueue().add_item(snatch_queue_item)
SnatchQueue().add_item(snatch_queue_item)