fix query log

rekby · rekby · commit ad3d5bbb6831 · 2024-07-24T19:02:23.000+03:00
diff --git a/log/query.go b/log/query.go
@@ -405,7 +405,7 @@ func internalQuery(
 			}
 			ctx := with(*info.Context, TRACE, "ydb", "query", "session", "execute")
 			l.Log(ctx, "start",
-				String("PartitionSessionID", info.Session.ID()),
+				String("SessionID", info.Session.ID()),
 				String("SessionStatus", info.Session.Status()),
 				String("Query", info.Query),
 			)
@@ -435,7 +435,7 @@ func internalQuery(
 			}
 			ctx := with(*info.Context, TRACE, "ydb", "query", "session", "begin")
 			l.Log(ctx, "start",
-				String("PartitionSessionID", info.Session.ID()),
+				String("SessionID", info.Session.ID()),
 				String("SessionStatus", info.Session.Status()),
 			)
 			start := time.Now()
@@ -465,7 +465,7 @@ func internalQuery(
 			}
 			ctx := with(*info.Context, TRACE, "ydb", "query", "transaction", "execute")
 			l.Log(ctx, "start",
-				String("PartitionSessionID", info.Session.ID()),
+				String("SessionID", info.Session.ID()),
 				String("TransactionID", info.Tx.ID()),
 				String("SessionStatus", info.Session.Status()),
 			)

Original file line number	Diff line number	Diff line change
`@@ -405,7 +405,7 @@ func internalQuery(`
`405`	`405`	`}`
`406`	`406`	`ctx := with(*info.Context, TRACE, "ydb", "query", "session", "execute")`
`407`	`407`	`l.Log(ctx, "start",`
`408`		`- String("PartitionSessionID", info.Session.ID()),`
	`408`	`+ String("SessionID", info.Session.ID()),`
`409`	`409`	`String("SessionStatus", info.Session.Status()),`
`410`	`410`	`String("Query", info.Query),`
`411`	`411`	`)`
`@@ -435,7 +435,7 @@ func internalQuery(`
`435`	`435`	`}`
`436`	`436`	`ctx := with(*info.Context, TRACE, "ydb", "query", "session", "begin")`
`437`	`437`	`l.Log(ctx, "start",`
`438`		`- String("PartitionSessionID", info.Session.ID()),`
	`438`	`+ String("SessionID", info.Session.ID()),`
`439`	`439`	`String("SessionStatus", info.Session.Status()),`
`440`	`440`	`)`
`441`	`441`	`start := time.Now()`
`@@ -465,7 +465,7 @@ func internalQuery(`
`465`	`465`	`}`
`466`	`466`	`ctx := with(*info.Context, TRACE, "ydb", "query", "transaction", "execute")`
`467`	`467`	`l.Log(ctx, "start",`
`468`		`- String("PartitionSessionID", info.Session.ID()),`
	`468`	`+ String("SessionID", info.Session.ID()),`
`469`	`469`	`String("TransactionID", info.Tx.ID()),`
`470`	`470`	`String("SessionStatus", info.Session.Status()),`
`471`	`471`	`)`