Fix ingest test

helium · Aug 26, 2024 · 653a82c · 653a82c
1 parent 9fd5420
commit 653a82c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/ingest/tests/common/mod.rs b/ingest/tests/common/mod.rs
@@ -44,6 +44,7 @@ pub async fn setup_mobile() -> anyhow::Result<(TestClient, Trigger)> {
     let (coverage_obj_tx, _rx) = tokio::sync::mpsc::channel(10);
     let (sp_boosted_tx, _rx) = tokio::sync::mpsc::channel(10);
     let (subscriber_mapping_tx, subscriber_mapping_rx) = tokio::sync::mpsc::channel(10);
+    let (promotion_rewards_tx, _rx) = tokio::sync::mpsc::channel(10);
 
     tokio::spawn(async move {
         let grpc_server = GrpcServer::new(
@@ -57,6 +58,7 @@ pub async fn setup_mobile() -> anyhow::Result<(TestClient, Trigger)> {
             FileSinkClient::new(coverage_obj_tx, "noop"),
             FileSinkClient::new(sp_boosted_tx, "noop"),
             FileSinkClient::new(subscriber_mapping_tx, "test_file_sink"),
+            FileSinkClient::new(promotion_rewards_tx, "noop"),
             Network::MainNet,
             socket_addr,
             api_token,