in curator/actions/reindex.py [0:0]
def sources(self):
"""Generator for Reindexing ``sources`` & ``dests``"""
dest = self.body['dest']['index']
source_list = ensure_list(self.body['source']['index'])
self.loggit.debug('source_list: %s', source_list)
if not source_list or source_list == ['REINDEX_SELECTED']: # Empty list
raise NoIndices
if not self.migration:
yield self.body['source']['index'], dest
# Loop over all sources (default will only be one)
else:
for source in source_list:
if self.migration:
dest = self.mpfx + source + self.msfx
yield source, dest