diff --git a/locust_influxdb_listener/__init__.py b/locust_influxdb_listener/__init__.py index 0086bbe..fc83df6 100644 --- a/locust_influxdb_listener/__init__.py +++ b/locust_influxdb_listener/__init__.py @@ -171,6 +171,7 @@ def __listen_for_requests_events(self, node_id, measurement, request_type, name, 'response_time': response_time, 'response_length': response_length, 'counter': self.env.stats.num_requests, # TODO: Review the need of this field + 'user_count': self.env.runner.user_count } point = self.__make_data_point(measurement, tags, fields, time) self.cache.append(point)