Method put

aura/worker_executor.py:109–112

(self, item)

        self.progressbar.update(0)

    async def put(self, item):
        await self.q.put(item)
        self.total += 1
        self._update_progress()

    def put_nowait(self, item):
        self.q.put_nowait(item)