Skip to content

Conversation

@Akhil-Pathivada
Copy link
Owner

No description provided.

…n for streaming tests

- Backend (mp_runner.py): Modified search_by_dur() to collect individual query latencies and calculate p99/p95/avg percentiles for each concurrency level
- Backend (read_write_runner.py): Updated run_search() and run_search_by_sig() to extract and propagate concurrent latency data through the streaming test pipeline
- Data Model (metric.py): Added 5 new fields to store concurrent latency data per stage: st_conc_num_list_list, st_conc_qps_list_list, st_conc_latency_p99_list_list, st_conc_latency_p95_list_list, st_conc_latency_avg_list_list
- Frontend: Created new concurrent_detail.py component with QPS vs Latency visualization featuring:
  * Single Stage view: Detailed QPS vs Latency chart with metrics table for one selected stage
  * Compare Stages view: Multi-line chart comparing QPS vs Latency evolution across multiple stages
  * Support for P99, P95, and Average latency metrics
  * Graceful handling of stages with no concurrent data
- Frontend (streaming.py): Integrated concurrent performance detail section into streaming results page

This enables users to answer 'At X QPS with writes happening, what is the latency?' for streaming workloads.
@Akhil-Pathivada Akhil-Pathivada changed the base branch from main to feat/custom-streaming-test-cluster December 4, 2025 16:36
@Akhil-Pathivada Akhil-Pathivada force-pushed the support-opensearch-prod-equivalent branch from 0fa05ab to c13ee29 Compare December 5, 2025 20:00
@Akhil-Pathivada Akhil-Pathivada changed the base branch from feat/custom-streaming-test-cluster to main December 5, 2025 20:02
@Akhil-Pathivada Akhil-Pathivada changed the base branch from main to feat/streaming-concurrent-latency December 5, 2025 20:06
@Akhil-Pathivada Akhil-Pathivada changed the base branch from feat/streaming-concurrent-latency to main December 5, 2025 20:06
@Akhil-Pathivada Akhil-Pathivada changed the base branch from main to feat/streaming-concurrent-latency-backup December 5, 2025 20:12
@Akhil-Pathivada Akhil-Pathivada changed the base branch from feat/streaming-concurrent-latency-backup to feat/streaming-concurrent-latency December 5, 2025 20:20
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants