Merge branch 'main' into feat/kinesis-binding-vmware-go-kcl-v2-latest

rideshnath-scout · web-flow · commit 2a205cb13099 · 2025-11-26T16:18:05.000+05:30
diff --git a/state/postgresql/v2/postgresql.go b/state/postgresql/v2/postgresql.go
@@ -251,15 +251,15 @@ CREATE INDEX ON %[1]s (expires_at);
 				}
 			}
 
-			// 2) Backfill NULLs deterministically (insertdate, key)
+			// 2) Backfill NULLs deterministically (created_at, key)
 			var nulls int64
 			if err := p.db.QueryRow(ctx, `SELECT COUNT(*) FROM `+fqtnQI+` WHERE row_id IS NULL`).Scan(&nulls); err != nil {
 				return fmt.Errorf("count NULL row_id: %w", err)
 			}
 			if nulls > 0 {
 				if _, err := p.db.Exec(ctx, `
 WITH ranked AS (
-  SELECT key, ROW_NUMBER() OVER (ORDER BY insertdate ASC, key ASC) AS rn
+  SELECT key, ROW_NUMBER() OVER (ORDER BY created_at ASC, key ASC) AS rn
   FROM `+fqtnQI+`
   WHERE row_id IS NULL
 )

Original file line number	Diff line number	Diff line change
`@@ -251,15 +251,15 @@ CREATE INDEX ON %[1]s (expires_at);`
`251`	`251`	`}`
`252`	`252`	`}`
`253`	`253`
`254`		`- // 2) Backfill NULLs deterministically (insertdate, key)`
	`254`	`+ // 2) Backfill NULLs deterministically (created_at, key)`
`255`	`255`	`var nulls int64`
`256`	`256`	if err := p.db.QueryRow(ctx, `SELECT COUNT(*) FROM `+fqtnQI+` WHERE row_id IS NULL`).Scan(&nulls); err != nil {
`257`	`257`	`return fmt.Errorf("count NULL row_id: %w", err)`
`258`	`258`	`}`
`259`	`259`	`if nulls > 0 {`
`260`	`260`	if _, err := p.db.Exec(ctx, `
`261`	`261`	`WITH ranked AS (`
`262`		`- SELECT key, ROW_NUMBER() OVER (ORDER BY insertdate ASC, key ASC) AS rn`
	`262`	`+ SELECT key, ROW_NUMBER() OVER (ORDER BY created_at ASC, key ASC) AS rn`
`263`	`263`	FROM `+fqtnQI+`
`264`	`264`	`WHERE row_id IS NULL`
`265`	`265`	`)`