def METHOD_NAME(self, log_lines: List[Tuple[str, int]], **kwargs):
    if self._state.get('cleanup'):
        return
    for (line, line_num) in log_lines:
        self.logs.track(LogLine(line), step=line_num + self._prev_logs_end)