// Setup mock components
        SearchEngineClient searchEngineClient = new SearchEngineClient() {
            @Override
            public PingResponse ping() {
                return new PingResponse(createMockHealthResponse("test-cluster", ClusterHealthStatus.GREEN));
            }
        };

        SystemHelper systemHelper = new SystemHelper() {
            @Override
            public boolean isChangedClusterState(int status) {