Skip to content

Commit c178be3

Browse files
authored
Start download counts backend in analyzer service (#8169)
1 parent 05ee255 commit c178be3

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

app/lib/service/entrypoint/analyzer.dart

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@ import '../../shared/popularity_storage.dart';
1919
import '../../task/backend.dart';
2020
import '../../tool/neat_task/pub_dev_tasks.dart';
2121

22+
import '../download_counts/backend.dart';
2223
import '_isolate.dart';
2324

2425
final Logger logger = Logger('pub.analyzer');
@@ -63,6 +64,7 @@ Future _workerMain(EntryMessage message) async {
6364
message.protocolSendPort.send(ReadyMessage());
6465

6566
await popularityStorage.start();
67+
await downloadCountsBackend.start();
6668
await taskBackend.start();
6769

6870
setupAnalyzerPeriodicTasks();
@@ -75,11 +77,13 @@ Future _workerMain(EntryMessage message) async {
7577
Future _indexBuilderMain(EntryMessage message) async {
7678
message.protocolSendPort.send(ReadyMessage());
7779
await popularityStorage.start();
80+
await downloadCountsBackend.start();
7881
await searchBackend.updateSnapshotInForeverLoop();
7982
}
8083

8184
Future _apiExporterMain(EntryMessage message) async {
8285
message.protocolSendPort.send(ReadyMessage());
8386
await popularityStorage.start();
87+
await downloadCountsBackend.start();
8488
await apiExporter!.uploadInForeverLoop();
8589
}

0 commit comments

Comments
 (0)