Pass down the provided timeout.
This commit is contained in:
parent
292e383d2c
commit
614aef2527
|
@ -180,7 +180,7 @@ public class PersistentTasksService extends AbstractComponent {
|
|||
public void onTimeout(TimeValue timeout) {
|
||||
listener.onFailure(new IllegalStateException("timed out after " + timeout));
|
||||
}
|
||||
}, clusterState -> predicate.test(clusterState.metaData().custom(PersistentTasksCustomMetaData.TYPE)));
|
||||
}, clusterState -> predicate.test(clusterState.metaData().custom(PersistentTasksCustomMetaData.TYPE)), timeout);
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue