#NEWLINE# def _ensure_icu_plugin( conn ) : #NEWLINE# #INDENT# 'Ensure that the ICU analysis plugin is installed for ES.' #NEWLINE# names = [ x . strip ( ) for x in conn . cat . plugins ( h = 'component' ) . split ( '\n' ) ] #NEWLINE# if ( 'analysis-icu' not in names ) : #NEWLINE# #INDENT# message = 'The Elasticsearch ICU Analysis plugin is not installed. Refer to https://github.com/elastic/elasticsearch-analysis-icu for installation instructions.' #NEWLINE# raise RuntimeError ( conn )