diff --git a/src/sentry/conf/server.py b/src/sentry/conf/server.py index 3720cd9b21f750..0f386d05906a26 100644 --- a/src/sentry/conf/server.py +++ b/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 diff --git a/src/sentry/runner/commands/devserver.py b/src/sentry/runner/commands/devserver.py index cda39c4d245d03..72db1f5dd47c0f 100644 --- a/src/sentry/runner/commands/devserver.py +++ b/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")] diff --git a/src/sentry/runner/commands/run.py b/src/sentry/runner/commands/run.py index 30b20f3d66ff3c..73064e1b3119ce 100644 --- a/src/sentry/runner/commands/run.py +++ b/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):