File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -108,7 +108,7 @@ await this.WaitForProductChanges(
108108 id => $ "Product { id } ",
109109 id => id * 100 ,
110110 this . GetBatchProcessingTimeout ( firstId , lastId , batchSize : batchSize ) ) ;
111- await taskCompletionSource . Task . TimeoutAfter ( TimeSpan . FromSeconds ( 5000 ) ) ;
111+ await taskCompletionSource . Task . TimeoutAfter ( TimeSpan . FromSeconds ( 5000 ) , "Timed out waiting for BatchSize configuration message" ) ;
112112 }
113113
114114 /// <summary>
@@ -122,7 +122,7 @@ public async Task PollingIntervalOverrideTriggerTest()
122122 // only wait for the expected time and timeout if the default polling
123123 // interval isn't actually modified.
124124 const int lastId = SqlTableChangeMonitor < object > . DefaultBatchSize * 5 ;
125- const int pollingIntervalMs = 75 ;
125+ const int pollingIntervalMs = SqlTableChangeMonitor < object > . DefaultPollingIntervalMs / 2 ;
126126 this . EnableChangeTrackingForTable ( "Products" ) ;
127127 var taskCompletionSource = new TaskCompletionSource < bool > ( ) ;
128128 DataReceivedEventHandler handler = TestUtils . CreateOutputReceievedHandler (
@@ -148,7 +148,7 @@ await this.WaitForProductChanges(
148148 id => $ "Product { id } ",
149149 id => id * 100 ,
150150 this . GetBatchProcessingTimeout ( firstId , lastId , pollingIntervalMs : pollingIntervalMs ) ) ;
151- await taskCompletionSource . Task . TimeoutAfter ( TimeSpan . FromSeconds ( 5000 ) ) ;
151+ await taskCompletionSource . Task . TimeoutAfter ( TimeSpan . FromSeconds ( 5000 ) , "Timed out waiting for PollingInterval configuration message" ) ;
152152 }
153153
154154 /// <summary>
You can’t perform that action at this time.
0 commit comments