From 717bbd9a9729378042359a5fbd989a3242f97ce0 Mon Sep 17 00:00:00 2001
From: Sarah Zakarias <zarah@google.com>
Date: Mon, 21 Oct 2024 10:54:12 +0000
Subject: [PATCH] Start download counts backend in analyzer service

---
 app/lib/service/entrypoint/analyzer.dart | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/app/lib/service/entrypoint/analyzer.dart b/app/lib/service/entrypoint/analyzer.dart
index 0476f8b9d1..832b1d0939 100644
--- a/app/lib/service/entrypoint/analyzer.dart
+++ b/app/lib/service/entrypoint/analyzer.dart
@@ -19,6 +19,7 @@ import '../../shared/popularity_storage.dart';
 import '../../task/backend.dart';
 import '../../tool/neat_task/pub_dev_tasks.dart';
 
+import '../download_counts/backend.dart';
 import '_isolate.dart';
 
 final Logger logger = Logger('pub.analyzer');
@@ -63,6 +64,7 @@ Future _workerMain(EntryMessage message) async {
   message.protocolSendPort.send(ReadyMessage());
 
   await popularityStorage.start();
+  await downloadCountsBackend.start();
   await taskBackend.start();
 
   setupAnalyzerPeriodicTasks();
@@ -75,11 +77,13 @@ Future _workerMain(EntryMessage message) async {
 Future _indexBuilderMain(EntryMessage message) async {
   message.protocolSendPort.send(ReadyMessage());
   await popularityStorage.start();
+  await downloadCountsBackend.start();
   await searchBackend.updateSnapshotInForeverLoop();
 }
 
 Future _apiExporterMain(EntryMessage message) async {
   message.protocolSendPort.send(ReadyMessage());
   await popularityStorage.start();
+  await downloadCountsBackend.start();
   await apiExporter!.uploadInForeverLoop();
 }