diff --git a/qwarc/__init__.py b/qwarc/__init__.py index 261bd14..c998f98 100644 --- a/qwarc/__init__.py +++ b/qwarc/__init__.py @@ -248,9 +248,8 @@ class QWARC: self._sleepTasks.remove(future) elif future.taskType == 'process': item = future.item - # TODO Replace all of this with `if future.cancelled():` try: - await future #TODO: Is this actually necessary? asyncio.wait only returns 'done' futures... + future.result() except concurrent.futures.CancelledError as e: # Got cancelled, nothing we can do about it, but let's log a warning if it's a process task if future.taskType == 'process':