move
This commit is contained in:
@@ -112,10 +112,10 @@ class Parser(threading.Thread):
|
||||
log("Parser.run: start")
|
||||
while True:
|
||||
try:
|
||||
clip = self.inq.get()
|
||||
backlog = self.inq.qsize()
|
||||
if backlog:
|
||||
log("Parser.run backlog", backlog)
|
||||
clip = self.inq.get()
|
||||
if clip is None:
|
||||
break
|
||||
self.outq.put(self._run(clip).strip())
|
||||
|
||||
Reference in New Issue
Block a user