ref(sentry-metrics): Run ingest-metrics-consumer in devserver

src/sentry/conf/server.py

@@ -1668,6 +1668,10 @@ def create_partitioned_queues(name):
 # store. MUST be a power of two.
 SENTRY_CHUNK_UPLOAD_BLOB_SIZE = 8 * 1024 * 1024  # 8MB
 
+# This flag tell DEVSERVICES to start the ingest-metrics-consumer in order to work on
+# metrics in the development environment. Note: this is "metrics" the product
+SENTRY_USE_METRICS_DEV = False
+
 # This flags activates the Change Data Capture backend in the development environment
 SENTRY_USE_CDC_DEV = False
 

src/sentry/runner/commands/devserver.py

@@ -30,6 +30,7 @@
         "--force-offset-reset",
         "latest",
     ],
+    "metrics": ["sentry", "run", "ingest-metrics-consumer"],
 }
 
 
@@ -232,6 +233,9 @@ def devserver(
             for name, topic in settings.KAFKA_SUBSCRIPTION_RESULT_TOPICS.items():
                 daemons += [_get_daemon("subscription-consumer", "--topic", topic, suffix=name)]
 
+        if settings.SENTRY_USE_METRICS_DEV and settings.SENTRY_USE_RELAY:
+            daemons += [_get_daemon("metrics")]
+
     if settings.SENTRY_USE_RELAY:
         daemons += [_get_daemon("ingest")]
 

src/sentry/runner/commands/run.py

@@ -526,15 +526,15 @@ def ingest_consumer(consumer_types, all_consumer_types, **options):
         get_ingest_consumer(consumer_types=consumer_types, executor=executor, **options).run()
 
 
-@run.command("metrics-consumer")
+@run.command("ingest-metrics-consumer")
 @log_options()
 @click.option(
     "--group_id",
-    default="metrics-consumer",
+    default="ingest-metrics-consumer",
     help="Consumer group to track metric indexer offsets. ",
 )
 @click.option("--topic", default="ingest-metrics", help="Topic to get subscription updates from.")
-@batching_kafka_options("metrics-consumer")
+@batching_kafka_options("ingest-metrics-consumer")
 @configuration
 def metrics_consumer(**options):