def _execute_tasks(self): self._poll() while not self._queue.empty(): task = dill.loads(self._queue.get()) _try_callback(self, task)