File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -335,6 +335,7 @@ jobs:
335335 --concurrency "${NUM_QUERY_CLIENTS}" \
336336 --scenario "${SCENARIO}" \
337337 --executor-instance-type "${EXECUTOR_INSTANCE_TYPE}" \
338+ --scrape-sut-metrics \
338339 ${ETL_ARGS} \
339340 ${ETL_SINK_ARGS} \
340341 ${VALIDATION_ARGS} \
Original file line number Diff line number Diff line change @@ -60,6 +60,14 @@ fn run_metric_attributes(common_args: &CommonArgs) -> Vec<KeyValue> {
6060 ) ]
6161}
6262
63+ fn log_sut_metrics_snapshot ( response : & MetricsResponse ) {
64+ tracing:: debug!(
65+ resource = ?response. resource,
66+ ingestion = ?response. ingestion,
67+ "SUT metrics snapshot retrieved before export"
68+ ) ;
69+ }
70+
6371/// Record the latest SUT metrics snapshot on the given streaming instruments.
6472#[ expect( clippy:: too_many_arguments) ]
6573fn record_sut_metrics (
@@ -155,6 +163,7 @@ fn spawn_sut_metrics_scraper(
155163 let metrics_result = adapter. lock( ) . await . metrics( run_id) . await ;
156164 match metrics_result {
157165 Ok ( resp) => {
166+ log_sut_metrics_snapshot( & resp) ;
158167 record_sut_metrics(
159168 & resp,
160169 & instruments,
@@ -175,6 +184,7 @@ fn spawn_sut_metrics_scraper(
175184 ( ) = token. cancelled( ) => {
176185 // Final scrape before exiting
177186 if let Ok ( resp) = adapter. lock( ) . await . metrics( run_id) . await {
187+ log_sut_metrics_snapshot( & resp) ;
178188 record_sut_metrics(
179189 & resp,
180190 & instruments,
You can’t perform that action at this time.
0 commit comments