|
|
@@ -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': |
|
|
|