diff --git a/src/launchpad/utils/arroyo_metrics.py b/src/launchpad/utils/arroyo_metrics.py index 11b915fb..302912d2 100644 --- a/src/launchpad/utils/arroyo_metrics.py +++ b/src/launchpad/utils/arroyo_metrics.py @@ -17,7 +17,7 @@ class DatadogMetricsBackend(Metrics): """ def __init__(self, group_id: str) -> None: - self._statsd = get_statsd("sentry.consumer") + self._statsd = get_statsd("consumer") self._constant_tags = {"consumer_group": group_id} def increment( diff --git a/src/launchpad/utils/statsd.py b/src/launchpad/utils/statsd.py index 9f69cd5b..9038ee5e 100644 --- a/src/launchpad/utils/statsd.py +++ b/src/launchpad/utils/statsd.py @@ -140,8 +140,8 @@ def timed(self, metric: str, tags: list[str] | None = None) -> Any: _namespace_to_statsd: dict[str, StatsdInterface] = {} -def get_statsd(custom_namespace: Literal[None, "sentry.consumer"] = None) -> StatsdInterface: - namespace = custom_namespace or "launchpad" +def get_statsd(namespace_suffix: Literal[None, "consumer"] = None) -> StatsdInterface: + namespace = f"launchpad.{namespace_suffix}" if namespace_suffix else "launchpad" if namespace in _namespace_to_statsd: return _namespace_to_statsd[namespace]