Method _update_progress

aura/worker_executor.py:101–107

(self)

        )

    def _update_progress(self):
        if config.PROGRESSBAR_DISABLED:
            return

        self.progressbar.total = self.total
        self.progressbar.n = self.completed
        self.progressbar.update(0)

    async def put(self, item):
        await self.q.put(item)