@@ -518,7 +518,7 @@ func TestContextPropagationFixes(t *testing.T) {
518518 newProvider := & testContextAwareProvider {initDelay : 10 * time .Millisecond }
519519
520520 // Use a short timeout that's shorter than the shutdown delay
521- replaceCtx , replaceCancel := context .WithTimeout (context .Background (), 200 * time .Millisecond )
521+ replaceCtx , replaceCancel := context .WithTimeout (context .Background (), 200 * time .Millisecond )
522522 defer replaceCancel ()
523523
524524 start := time .Now ()
@@ -568,7 +568,6 @@ func TestContextPropagationFixes(t *testing.T) {
568568
569569 newProvider := & testContextAwareProvider {initDelay : 10 * time .Millisecond }
570570 err = SetProviderWithContextAndWait (replaceCtx , newProvider )
571-
572571 // Should succeed because init is fast, shutdown is async
573572 if err != nil {
574573 t .Errorf ("Provider replacement should succeed even with cancellation: %v" , err )
@@ -736,7 +735,6 @@ func TestEdgeCases(t *testing.T) {
736735 api = testAPI
737736 eventing = exec
738737
739-
740738 t .Run ("rapid provider switching" , func (t * testing.T ) {
741739 // Reset API
742740 exec = newEventExecutor ()
@@ -796,7 +794,7 @@ func TestEdgeCases(t *testing.T) {
796794 }()
797795
798796 // Wait for both to complete
799- for i := 0 ; i < 2 ; i ++ {
797+ for i := range 2 {
800798 if err := <- done ; err != nil {
801799 t .Errorf ("Concurrent operation %d failed: %v" , i , err )
802800 }
0 commit comments