We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3ec4cc1 commit d546626Copy full SHA for d546626
src/sentry/runner/commands/run.py
@@ -653,11 +653,12 @@ def metrics_parallel_consumer(**options):
653
ingest_config = get_ingest_config(use_case, db_backend)
654
slicing_router = get_slicing_router(ingest_config)
655
656
+ initialize_global_consumer_state(ingest_config)
657
+
658
streamer = get_parallel_metrics_consumer(
659
indexer_profile=ingest_config, slicing_router=slicing_router, **options
660
)
661
- initialize_global_consumer_state(ingest_config)
662
run_processor_with_signals(streamer)
663
664
0 commit comments