Perf - Fix ingesting tx_log files.
We would previously try to ingest files from the transaction log, (tx_log), but
to speed things up I returned early, but w/o setting success=true, which means
the msg would be nack'd and put back on the queue for a later ingestion. Eventually
the backlog swamped real data files.
Change-Id: I3639564aa8a906a8a57badc63bcba404c34ba8b1
Reviewed-on: https://skia-review.googlesource.com/c/buildbot/+/234357
Commit-Queue: Joe Gregorio <jcgregorio@google.com>
Reviewed-by: Ravi Mistry <rmistry@google.com>
diff --git a/perf/go/perf-ingest/main.go b/perf/go/perf-ingest/main.go
index 5251e47..815d8a0 100644
--- a/perf/go/perf-ingest/main.go
+++ b/perf/go/perf-ingest/main.go
@@ -280,6 +280,8 @@
// Transaction logs for android_ingest are written to the same bucket,
// which we should ignore.
if strings.Contains(event.Name, "/tx_log/") {
+ // Ack the file so we don't process it again.
+ success = true
return
}
// Load the file.
