Convert labels to str ourselves

This is done internally (if you read the code) but the type annotations
now require str.

Author: reivilibre

synapse/handlers/register.py

@@ -68,11 +68,11 @@ def init_counters_for_auth_provider(auth_provider_id: str) -> None:
     until the user first logs in/registers.
     """
     for is_guest in (True, False):
-        login_counter.labels(guest=is_guest, auth_provider=auth_provider_id)
+        login_counter.labels(guest=str(is_guest), auth_provider=auth_provider_id)
         for shadow_banned in (True, False):
             registration_counter.labels(
-                guest=is_guest,
-                shadow_banned=shadow_banned,
+                guest=str(is_guest),
+                shadow_banned=str(shadow_banned),
                 auth_provider=auth_provider_id,
             )
 
@@ -341,8 +341,8 @@ async def register_user(
                     fail_count += 1
 
         registration_counter.labels(
-            guest=make_guest,
-            shadow_banned=shadow_banned,
+            guest=str(make_guest),
+            shadow_banned=str(shadow_banned),
             auth_provider=(auth_provider_id or ""),
         ).inc()
 
@@ -775,7 +775,7 @@ async def register_device(
         )
 
         login_counter.labels(
-            guest=is_guest,
+            guest=str(is_guest),
             auth_provider=(auth_provider_id or ""),
         ).inc()
 

synapse/metrics/_gc.py

@@ -123,8 +123,8 @@ def _maybe_gc() -> None:
 
                 _last_gc[i] = end
 
-                gc_time.labels(i).observe(end - start)
-                gc_unreachable.labels(i).set(unreachable)
+                gc_time.labels(str(i)).observe(end - start)
+                gc_unreachable.labels(str(i)).set(unreachable)
 
     gc_task = task.LoopingCall(_maybe_gc)
     gc_task.start(0.1)

synapse/replication/http/_base.py

@@ -257,13 +257,13 @@ async def send_request(*, instance_name="master", **kwargs):
                     # We convert to SynapseError as we know that it was a SynapseError
                     # on the main process that we should send to the client. (And
                     # importantly, not stack traces everywhere)
-                    _outgoing_request_counter.labels(cls.NAME, e.code).inc()
+                    _outgoing_request_counter.labels(cls.NAME, str(e.code)).inc()
                     raise e.to_synapse_error()
                 except Exception as e:
                     _outgoing_request_counter.labels(cls.NAME, "ERR").inc()
                     raise SynapseError(502, "Failed to talk to main process") from e
 
-                _outgoing_request_counter.labels(cls.NAME, 200).inc()
+                _outgoing_request_counter.labels(cls.NAME, "200").inc()
                 return result
 
         return send_request

synapse/replication/tcp/external_cache.py

@@ -115,7 +115,7 @@ async def get(self, cache_name: str, key: str) -> Optional[Any]:
 
         logger.debug("Got cache result %s %s: %r", cache_name, key, result)
 
-        get_counter.labels(cache_name, result is not None).inc()
+        get_counter.labels(cache_name, str(result is not None)).inc()
 
         if not result:
             return None