Searched refs:timestamp_tracker (Results 1 – 2 of 2) 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))
34 def _log_line_func(log, timestamp_tracker): argument37 timestamp_tracker.read_output(message)69 timestamp_tracker = TimestampTracker()70 syslog.set_on_output_callback(_log_line_func(logger, timestamp_tracker))