- def stderr_log_records(job_uuids, extra_filters = nil)
- filters = [["event_type", "=", "stderr"],
- ["object_uuid", "in", job_uuids]]
- filters += extra_filters if extra_filters
- last_entry = Log.select(%w(event_at)).order('id DESC').limit(1).filter(filters).results.first
- if last_entry
- filters += [["event_at", ">=", last_entry.event_at - 10.minutes]]
- Log.select(%w(event_type object_uuid event_at properties))
- .order('id DESC')
- .filter(filters)
- .results
- else
- []
- end
- end
-