Skip to content

Commit c4b35ab

Browse files
Copilotdevstress
andcommitted
Change observability test to use 1 million messages for real throughput testing
- Changed KafkaMessages from 100 to 1,000,000 for realistic throughput measurement - Extended HTTP client timeout from 5 to 30 minutes to accommodate larger processing time - Increased wait time from 2 to 10 seconds for metrics recording - Updated comments to reflect the throughput testing purpose Co-authored-by: devstress <30769729+devstress@users.noreply.github.com>
1 parent 3830ec6 commit c4b35ab

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

LocalTesting/LocalTesting.IntegrationTests/StepDefinitions/ObservabilityMetricsSteps.cs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ private async Task EnsureInfrastructureInitialized()
4848

4949
// Create HTTP client with service discovery - use the correct endpoint name "webapi"
5050
_httpClient = _app.CreateHttpClient("localtesting-webapi", "webapi");
51-
_httpClient.Timeout = TimeSpan.FromMinutes(5); // Reasonable timeout for observability tests
51+
_httpClient.Timeout = TimeSpan.FromMinutes(30); // Extended timeout for 1M messages processing
5252

5353
lock (_lockObject)
5454
{
@@ -84,10 +84,10 @@ public async Task WhenISimulateObservabilityMetricsAcrossAllLayers()
8484
{
8585
await EnsureInfrastructureInitialized();
8686

87-
// Use the observability simulation endpoint with reasonable test data
87+
// Use the observability simulation endpoint with 1 million messages for real throughput testing
8888
var simulationRequest = new
8989
{
90-
KafkaMessages = 100,
90+
KafkaMessages = 1000000,
9191
FlinkJobs = 2,
9292
TemporalWorkflows = 5,
9393
DurationSeconds = 10
@@ -96,8 +96,8 @@ public async Task WhenISimulateObservabilityMetricsAcrossAllLayers()
9696
var response = await _httpClient!.PostAsJsonAsync("/api/observability/metrics/simulate", simulationRequest);
9797
response.EnsureSuccessStatusCode();
9898

99-
// Wait for metrics to be recorded
100-
await Task.Delay(2000);
99+
// Wait longer for 1M messages to be processed and metrics to be recorded
100+
await Task.Delay(10000);
101101

102102
_scenarioContext["simulation_completed"] = true;
103103
}

0 commit comments

Comments
 (0)