source-postgres: Trivial cleanups from PR feedback

willdonnelly · willdonnelly · commit a6d3ee042e05 · 2025-07-10T11:27:38.000-05:00
diff --git a/source-postgres/replication.go b/source-postgres/replication.go
@@ -347,7 +347,6 @@ func (s *replicationStream) StreamToFence(ctx context.Context, fenceAfter time.D
 	}
 
 	// Stream replication events until the fence is reached or the watchdog timeout hits.
-	//
 	var relayCtx, cancelRelayCtx = context.WithCancelCause(ctx)
 	defer cancelRelayCtx(nil)
 
@@ -845,7 +844,6 @@ func (s *replicationStream) decodeChangeEvent(
 		s.reused.rowKey = rowKey // Update in case of resizing
 	}
 
-	_ = beforeValues // TODO(wgd): Include the before tuple values so that updates with full REPLICA IDENTITY work correctly.
 	*s.reused.changeEvent = postgresChangeEvent{
 		Info: info.Shared,
 		Meta: postgresChangeMetadata{

Original file line number	Diff line number	Diff line change
`@@ -347,7 +347,6 @@ func (s *replicationStream) StreamToFence(ctx context.Context, fenceAfter time.D`
`347`	`347`	`}`
`348`	`348`
`349`	`349`	`// Stream replication events until the fence is reached or the watchdog timeout hits.`
`350`		`- //`
`351`	`350`	`var relayCtx, cancelRelayCtx = context.WithCancelCause(ctx)`
`352`	`351`	`defer cancelRelayCtx(nil)`
`353`	`352`
`@@ -845,7 +844,6 @@ func (s *replicationStream) decodeChangeEvent(`
`845`	`844`	`s.reused.rowKey = rowKey // Update in case of resizing`
`846`	`845`	`}`
`847`	`846`
`848`		`- _ = beforeValues // TODO(wgd): Include the before tuple values so that updates with full REPLICA IDENTITY work correctly.`
`849`	`847`	`*s.reused.changeEvent = postgresChangeEvent{`
`850`	`848`	`Info: info.Shared,`
`851`	`849`	`Meta: postgresChangeMetadata{`