Searched refs:timestamp_tracker (Results 1 – 1 of 1) sorted by relevance
61 def _log_line_func(log, timestamp_tracker): argument65 timestamp_tracker.read_output(message)71 def _on_retry(serial, extra_params, timestamp_tracker): argument73 begin_at = '"%s"' % (timestamp_tracker.last_timestamp or 1)98 timestamp_tracker = TimestampTracker()99 process.set_on_output_callback(_log_line_func(logger, timestamp_tracker))101 _on_retry(serial, extra_params, timestamp_tracker))