Removed timeout

allegro · Oct 16, 2023 · 5cd9edd · 5cd9edd
1 parent 1abb570
commit 5cd9edd
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/...rc/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/synchronization/RemoteServices.kt b/...rc/main/kotlin/pl/allegro/tech/servicemesh/envoycontrol/synchronization/RemoteServices.kt
@@ -57,7 +57,6 @@ class RemoteServices(
     ): CompletableFuture<ClusterState?> {
         return controlPlaneClient.getState(chooseInstance(instances))
             .thenApply { servicesStateFromCluster(cluster, it) }
-            .orTimeout(interval, TimeUnit.SECONDS)
             .exceptionally {
                 meterRegistry.counter("cross-dc-synchronization.$cluster.state-fetcher.errors").increment()
                 logger.warn("Error synchronizing instances ${it.message}", it)