diff --git a/src/main/kotlin/com/amazon/elasticsearch/replication/util/Coroutines.kt b/src/main/kotlin/com/amazon/elasticsearch/replication/util/Coroutines.kt
index 48ab1ecf..dce9f25b 100644
--- a/src/main/kotlin/com/amazon/elasticsearch/replication/util/Coroutines.kt
+++ b/src/main/kotlin/com/amazon/elasticsearch/replication/util/Coroutines.kt
@@ -129,7 +129,7 @@ suspend fun ClusterStateObserver.waitForNextChange(reason: String, predicate: (C
             override fun onTimeout(timeout: TimeValue?) {
                 cont.resumeWithException(ElasticsearchTimeoutException("timed out waiting for $reason"))
             }
-        }, predicate)
+        }, predicate,  TimeValue(60000))
     }
 }