Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
only one evaluation per alias allowed
  • Loading branch information
garbas committed Jun 3, 2020
1 parent ae67099 commit fc54fe9
Showing 1 changed file with 18 additions and 3 deletions.
21 changes: 18 additions & 3 deletions scripts/import-channel
Expand Up @@ -303,8 +303,22 @@ def create_index_name(channel, evaluation):


def update_alias(es, name, index):
es.indices.put_alias(index=index, name=name)
logger.debug(f"'{name}' alias now points to '{index}' index")
indexes = set(es.indices.get_alias(name=name).keys())

# indexes to remove from alias
actions = [
{"remove": {"index": item, "alias": name}}
for item in indexes.difference(set([index]))
]

# add index if does not exists in alias
if index not in indexes:
actions.append({"add": {"index": index, "alias": name}})

es.indices.update_aliases({"actions": actions})

indexes = ", ".join(es.indices.get_alias(name=name).keys())
logger.debug(f"'{name}' alias now points to '{indexes}' index")


def write(unit, es, index_name, number_of_items, item_generator):
Expand Down Expand Up @@ -346,7 +360,8 @@ def main(es_url, channel, verbose):
if index_created:
write("packages", es, index_name, *get_packages(evaluation))
write("options", es, index_name, *get_options(evaluation))
update_alias(es, alias_name, index_name)

update_alias(es, alias_name, index_name)


if __name__ == "__main__":
Expand Down

0 comments on commit fc54fe9

Please sign in to comment.