@@ -778,21 +778,21 @@ func TestReaper_ShutdownOldWorkers(t *testing.T) {
778778func TestReaper_CreateSourceHelpers (t * testing.T ) {
779779 ctx := log .WithLogger (t .Context (), log .NewNoopLogger ())
780780
781- t .Run ("skips already initialized source" , func (t * testing.T ) {
781+ t .Run ("skips already initialized source" , func (* testing.T ) {
782782 r := NewReaper (ctx , & cmdopts.Options {})
783783 md := & sources.SourceConn {Source : sources.Source {Name : "existing" }}
784784 r .prevLoopMonitoredDBs = sources.SourceConns {md }
785785 // Conn is nil — would panic if used, proving early return
786786 r .CreateSourceHelpers (ctx , r .logger , md )
787787 })
788788
789- t .Run ("skips non-postgres source" , func (t * testing.T ) {
789+ t .Run ("skips non-postgres source" , func (* testing.T ) {
790790 r := NewReaper (ctx , & cmdopts.Options {})
791791 md := & sources.SourceConn {Source : sources.Source {Name : "pgbouncer" , Kind : sources .SourcePgBouncer }}
792792 r .CreateSourceHelpers (ctx , r .logger , md )
793793 })
794794
795- t .Run ("skips source in recovery" , func (t * testing.T ) {
795+ t .Run ("skips source in recovery" , func (* testing.T ) {
796796 r := NewReaper (ctx , & cmdopts.Options {})
797797 md := & sources.SourceConn {
798798 Source : sources.Source {Name : "standby" },
0 commit comments