From 2b0778f9b5b60e45c727f7c2a9ec2561f1662ff3 Mon Sep 17 00:00:00 2001 From: JustAnotherArchivist Date: Fri, 26 Jul 2019 15:54:46 +0000 Subject: [PATCH] Remove leftovers from initial code rewrite --- qwarc/__init__.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/qwarc/__init__.py b/qwarc/__init__.py index 9f4d3d5..a81647b 100644 --- a/qwarc/__init__.py +++ b/qwarc/__init__.py @@ -197,7 +197,7 @@ class QWARC: try: async def wait_for_free_task(): - nonlocal tasks, freeSessions, db, emptyTodoSleep + nonlocal tasks, freeSessions, db done, pending = await asyncio.wait(tasks, return_when = concurrent.futures.FIRST_COMPLETED) for future in done: # TODO Replace all of this with `if future.cancelled():` @@ -236,7 +236,6 @@ class QWARC: while True: while len(tasks) >= self._concurrency: - emptyTodoFullReached = True await wait_for_free_task() if self._minFreeDisk and qwarc.utils.too_little_disk_space(self._minFreeDisk): @@ -269,7 +268,6 @@ class QWARC: # create_db could insert a dummy item which is marked as done when the DB is ready cursor.execute('COMMIT') break - emptyTodoSleep = 0 id, itemType, itemValue, status = result cursor.execute('UPDATE items SET status = ? WHERE id = ?', (STATUS_INPROGRESS, id)) cursor.execute('COMMIT')