Method completed_cb

aura/worker_executor.py:57–59

(self, _)

        self.pg.close()

    def completed_cb(self, _):
        self.completed += 1
        self._update_progress()

    def submit(self, fn, *args, **kwargs) -> futures.Future:
        future = self.executor.submit(fn, *args, **kwargs)