message size grpc client (#2147)

nuclia · May 15, 2024 · 8d3c01a · 8d3c01a · github-actions · May 15, 2024
1 parent c90160b
commit 8d3c01a
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/nucliadb_node/src/replication/replicator.rs b/nucliadb_node/src/replication/replicator.rs
@@ -203,8 +203,9 @@ pub async fn connect_to_primary_and_replicate(
     }
     eprintln!("Connecting to primary: {:?}", primary_address);
     let mut client =
-        replication::replication_service_client::ReplicationServiceClient::connect(primary_address.clone()).await?;
-    // .max_decoding_message_size(256 * 1024 * 1024)
+        replication::replication_service_client::ReplicationServiceClient::connect(primary_address.clone())
+            .await?
+            .max_decoding_message_size(256 * 1024 * 1024);
     // .max_encoding_message_size(256 * 1024 * 1024);address);
 
     let repl_health_mng = ReplicationHealthManager::new(settings.clone());