Method task_done

aura/worker_executor.py:125–128

(self)

        return self.get_nowait()

    def task_done(self):
        self.completed += 1
        self.q.task_done()
        self._update_progress()

    async def join(self):
        return await self.q.join()