diff --git a/src/load_generator/load_gen/RequestScheduler.py b/src/load_generator/load_gen/RequestScheduler.py index 080e607d784c14131d9dd3d716e4fb5675622048..08876e29fa7da3f50ba78553a6aee81f0add7b56 100644 --- a/src/load_generator/load_gen/RequestScheduler.py +++ b/src/load_generator/load_gen/RequestScheduler.py @@ -97,6 +97,9 @@ class RequestScheduler: if request is None: LOGGER.warning('No resources available to compose new request') + metrics = METRICS_POOL.get_metrics_loadgen('setup', labels={'request_type': request_type}) + _, _, _, _, counter_blocked = metrics + counter_blocked.inc() return if 'service_id' in request: @@ -150,8 +153,8 @@ class RequestScheduler: ) -> None: if self._parameters.dry_mode: return - metrics = METRICS_POOL.get_metrics('setup', labels={'request_type': request_type}) - histogram_duration, counter_started, counter_completed, counter_failed = metrics + metrics = METRICS_POOL.get_metrics_loadgen('setup', labels={'request_type': request_type}) + histogram_duration, counter_started, counter_completed, counter_failed, _ = metrics service_id = None if service is not None: @@ -213,8 +216,8 @@ class RequestScheduler: ) -> None: if self._parameters.dry_mode: return - metrics = METRICS_POOL.get_metrics('teardown', labels={'request_type': request_type}) - histogram_duration, counter_started, counter_completed, counter_failed = metrics + metrics = METRICS_POOL.get_metrics_loadgen('teardown', labels={'request_type': request_type}) + histogram_duration, counter_started, counter_completed, counter_failed, _ = metrics if self._parameters.record_to_dlt: entities_to_record = explore_entities_to_record(slice_id=slice_id, service_id=service_id)