Runner: add log to know the cancelled reason.

This commit is contained in:
Chi Song 2022-09-27 10:33:44 -07:00 коммит произвёл Chi Song
Родитель f7d6b896af
Коммит fa007d383a
2 изменённых файлов: 2 добавлений и 1 удалений

Просмотреть файл

@ -220,8 +220,8 @@ class RootRunner(Action):
self._start_loop()
except Exception as identifier:
self._log.info(f"canceling runner due to exception: {identifier}")
cancel()
raise identifier
finally:
self._cleanup()

Просмотреть файл

@ -102,6 +102,7 @@ class TaskManager(Generic[T_RESULT]):
self._futures.append(future)
def cancel(self) -> None:
self._log.info("Called to cancel all tasks.")
self._cancelled = True
def check_cancelled(self) -> None: