Using time out in cluster state observer as we are reusing the observ…

…er (opensearch-project#215)

Signed-off-by: Gaurav Bafna <[email protected]>

src/main/kotlin/org/opensearch/replication/util/Coroutines.kt

@@ -125,7 +125,7 @@ suspend fun ClusterStateObserver.waitForNextChange(reason: String, predicate: (C
             override fun onTimeout(timeout: TimeValue?) {
                 cont.resumeWithException(OpenSearchTimeoutException("timed out waiting for $reason"))
             }
-        }, predicate)
+        }, predicate,  TimeValue(60000))
     }
 }