Fix fleet.migration.total log key overlap (#1951)

Co-authored-by: Anderson Queiroz <[email protected]>
elastic · Oct 6, 2022 · 60ba1cf · 60ba1cf
1 parent b2f3e20
commit 60ba1cf
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/CHANGELOG.next.asciidoc b/CHANGELOG.next.asciidoc
@@ -14,6 +14,7 @@
 - Update apikey.cache_hit log field name to match convention. {pull}1900[1900]
 - LoadServerLimits will not overwrite specified limits when loading default/agent number specified values. {issue}1841[1841] {pull}1912[1912]
 - Use seperate rate limiters for internal and external API listeners. {issue}1859[1859] {pull}1904[1904]
+- Fix fleet.migration.total log key overlap {pull}1951[1951]
 
 ==== New Features
 

diff --git a/internal/pkg/dl/migration.go b/internal/pkg/dl/migration.go
@@ -123,7 +123,6 @@ func applyMigration(ctx context.Context, name string, index string, bulker bulk.
 		Str("fleet.migration.name", name).
 		Int("fleet.migration.es.took", resp.Took).
 		Bool("fleet.migration.es.timed_out", resp.TimedOut).
-		Int("fleet.migration.total", resp.Total).
 		Int("fleet.migration.updated", resp.Updated).
 		Int("fleet.migration.deleted", resp.Deleted).
 		Int("fleet.migration.batches", resp.Batches).
@@ -132,6 +131,7 @@ func applyMigration(ctx context.Context, name string, index string, bulker bulk.
 		Int("fleet.migration.retries.bulk", resp.Retries.Bulk).
 		Int("fleet.migration.retries.search", resp.Retries.Search).
 		Dur("fleet.migration.total.duration", time.Since(start)).
+		Int("fleet.migration.total.count", resp.Total).
 		Msgf("migration %s done", name)
 
 	for _, fail := range resp.Failures {