This commit is contained in:
ed 2022-07-03 01:40:30 +02:00
parent efded35c2e
commit 1c0071d9ce

View file

@ -967,6 +967,9 @@ class Up2k(object):
warks = [str(x[0]) for x in zq]
jobs = []
for w in warks:
if w in in_progress:
continue
q = "select rd, fn from up where substr(w,1,16)=? limit 1"
rd, fn = cur.execute(q, (w,)).fetchone()
rd, fn = s3dec(rd, fn)
@ -982,9 +985,6 @@ class Up2k(object):
n_left -= 1
continue
if w in in_progress:
continue
jobs.append(Mpqe(parsers, set(), w, abspath))
in_progress[w] = True