in curator/indexlist.py [0:0]
def data_getter(self, data, exec_func):
"""
Function that prevents unnecessary code repetition for different data
getter methods
"""
self.loggit.debug('BEGIN data_getter')
checking = True
while checking:
working_list = self.indices_exist(data, exec_func)
if working_list:
for index in list(working_list.keys()):
try:
sii = self.index_info[index]
except KeyError:
self.loggit.warning(
'Index %s was not present at IndexList initialization, '
' and may be behind an alias',
index,
)
self.mitigate_alias(index)
sii = self.index_info[index]
working_list = {}
try:
working_list.update(self._bulk_queries(data, exec_func))
except NotFoundError as err:
data.remove(self.__remove_missing(err))
continue
yield sii, working_list[index], index
checking = False