import when needed

getsentry · Oct 4, 2023 · 4105d72 · 4105d72
1 parent 4bd1d42
commit 4105d72
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/sentry/cogs/accountant.py b/src/sentry/cogs/accountant.py
@@ -6,8 +6,6 @@
 from django.conf import settings
 from usageaccountant import UsageAccumulator, UsageUnit
 
-from sentry.utils.kafka_config import get_kafka_producer_cluster_options, get_topic_definition
-
 logger = logging.getLogger("usageaccountant")
 
 
@@ -17,6 +15,11 @@
 def _accumulator(create: bool = False) -> UsageAccumulator | None:
     global accumulator
     if accumulator is None and create:
+        from sentry.utils.kafka_config import (
+            get_kafka_producer_cluster_options,
+            get_topic_definition,
+        )
+
         producer = KafkaProducer(
             build_kafka_configuration(
                 get_kafka_producer_cluster_options(