Loading src/executor/task.py +5 −3 Original line number Diff line number Diff line Loading @@ -16,7 +16,7 @@ class Task: params: list[Any], timeout_s: int | None = None, name: str = "", task_progress_info: dict[str, str] = {}) -> None: task_progress_info: dict[str, str] | None = None) -> None: """ Creates a generic task to be executed :param executable: callable to the task executable, it is expected to throw exception on failure Loading @@ -33,6 +33,7 @@ class Task: self.finished_successfully: bool = False assert task_progress_info is not None, "task_progress_info is required" self.task_progress_info: dict[str, str] = task_progress_info def execute(self) -> Any: Loading Loading @@ -89,7 +90,7 @@ class TaskList(Task): chain_output: bool = True, timeout_s: int | None = None, name: str = "", task_progress_info: dict[str, str] = {}) -> None: task_progress_info: dict[str, str] | None = None) -> None: """ Creates a chained list of tasks to be executed in order :param tasks: list of tasks to be executed, in order Loading @@ -100,7 +101,8 @@ class TaskList(Task): super().__init__(lambda: True, [], timeout_s, name) name, task_progress_info) self._tasks: list[Task] = tasks self._chain_output: bool = chain_output Loading Loading
src/executor/task.py +5 −3 Original line number Diff line number Diff line Loading @@ -16,7 +16,7 @@ class Task: params: list[Any], timeout_s: int | None = None, name: str = "", task_progress_info: dict[str, str] = {}) -> None: task_progress_info: dict[str, str] | None = None) -> None: """ Creates a generic task to be executed :param executable: callable to the task executable, it is expected to throw exception on failure Loading @@ -33,6 +33,7 @@ class Task: self.finished_successfully: bool = False assert task_progress_info is not None, "task_progress_info is required" self.task_progress_info: dict[str, str] = task_progress_info def execute(self) -> Any: Loading Loading @@ -89,7 +90,7 @@ class TaskList(Task): chain_output: bool = True, timeout_s: int | None = None, name: str = "", task_progress_info: dict[str, str] = {}) -> None: task_progress_info: dict[str, str] | None = None) -> None: """ Creates a chained list of tasks to be executed in order :param tasks: list of tasks to be executed, in order Loading @@ -100,7 +101,8 @@ class TaskList(Task): super().__init__(lambda: True, [], timeout_s, name) name, task_progress_info) self._tasks: list[Task] = tasks self._chain_output: bool = chain_output Loading