diff --git a/copyparty/up2k.py b/copyparty/up2k.py
index bde9e84c..e1e1f3d1 100644
--- a/copyparty/up2k.py
+++ b/copyparty/up2k.py
@@ -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