Merge pull request nyaruka#43 from nyaruka/log_status

rowanseymour · web-flow · commit 6fa5a232f38a · 2022-03-30T12:39:32.000-07:00
If indexing fails, log status code from elasticsearch
diff --git a/indexers/base.go b/indexers/base.go
@@ -255,7 +255,7 @@ func (i *baseIndexer) indexBatch(index string, batch []byte) (int, int, error) {
 			} else if item.Index.Status == 409 {
 				conflictedCount++
 			} else {
-				logrus.WithField("id", item.Index.ID).WithField("batch", batch).WithField("result", item.Index.Result).Error("error indexing document")
+				logrus.WithField("id", item.Index.ID).WithField("status", item.Index.Status).WithField("result", item.Index.Result).Error("error indexing document")
 			}
 		} else if item.Delete.ID != "" {
 			logrus.WithField("id", item.Index.ID).WithField("status", item.Index.Status).Debug("delete response")

Original file line number	Diff line number	Diff line change
`@@ -255,7 +255,7 @@ func (i *baseIndexer) indexBatch(index string, batch []byte) (int, int, error) {`
`255`	`255`	`} else if item.Index.Status == 409 {`
`256`	`256`	`conflictedCount++`
`257`	`257`	`} else {`
`258`		`- logrus.WithField("id", item.Index.ID).WithField("batch", batch).WithField("result", item.Index.Result).Error("error indexing document")`
	`258`	`+ logrus.WithField("id", item.Index.ID).WithField("status", item.Index.Status).WithField("result", item.Index.Result).Error("error indexing document")`
`259`	`259`	`}`
`260`	`260`	`} else if item.Delete.ID != "" {`
`261`	`261`	`logrus.WithField("id", item.Index.ID).WithField("status", item.Index.Status).Debug("delete response")`