@@ -612,7 +612,7 @@ def record_config(self, config, extra_config):
612612
613613 def push_config_stats (self ):
614614 """push config stats to redis."""
615- self ._redis_client .hset (self ._TELEMETRY_CONFIG_KEY , 'python-' + self ._sdk_metadata .sdk_version + '/' + self ._sdk_metadata .instance_name + '/' + self ._sdk_metadata .instance_ip , str (self ._format_config_stats ()))
615+ self ._redis_client .hset (self ._TELEMETRY_CONFIG_KEY , self ._sdk_metadata .sdk_version + '/' + self ._sdk_metadata .instance_name + '/' + self ._sdk_metadata .instance_ip , str (self ._format_config_stats ()))
616616
617617 def _format_config_stats (self ):
618618 """format only selected config stats to json"""
@@ -646,7 +646,7 @@ def add_latency_to_pipe(self, method, latency, pipe):
646646 bucket_number = 0
647647 for bucket in values :
648648 if bucket > 0 :
649- pipe .hincrby (self ._TELEMETRY_LATENCIES_KEY , 'python-' + self ._sdk_metadata .sdk_version + '/' + self ._sdk_metadata .instance_name + '/' + self ._sdk_metadata .instance_ip + '/' +
649+ pipe .hincrby (self ._TELEMETRY_LATENCIES_KEY , self ._sdk_metadata .sdk_version + '/' + self ._sdk_metadata .instance_name + '/' + self ._sdk_metadata .instance_ip + '/' +
650650 method .value + '/' + str (bucket_number ), bucket )
651651 total_keys += 1
652652 bucket_number = bucket_number + 0
@@ -665,7 +665,7 @@ def record_exception(self, method):
665665 :type method: string
666666 """
667667 pipe = self ._make_pipe ()
668- pipe .hincrby (self ._TELEMETRY_EXCEPTIONS_KEY , 'python-' + self ._sdk_metadata .sdk_version + '/' + self ._sdk_metadata .instance_name + '/' + self ._sdk_metadata .instance_ip + '/' +
668+ pipe .hincrby (self ._TELEMETRY_EXCEPTIONS_KEY , self ._sdk_metadata .sdk_version + '/' + self ._sdk_metadata .instance_name + '/' + self ._sdk_metadata .instance_ip + '/' +
669669 method .value , 1 )
670670 result = pipe .execute ()
671671 self .expire_keys (self ._TELEMETRY_EXCEPTIONS_KEY , self ._TELEMETRY_KEY_DEFAULT_TTL , 1 , result [0 ])
0 commit comments