def assign_aliases()

in src/es_pii_tool/helpers/steps.py [0:0]

• 28 lines of code
• 5 McCabe index (conditional complexity)

def assign_aliases(task: 'Task', stepname, var: DotMap, **kwargs) -> None:
    """Put the starting index name on new mounted index as alias"""
    missing_data(stepname, kwargs)
    data = kwargs['data']
    step = Step(task=task, stepname=stepname)
    if step.finished():
        logger.info('%s: already completed', step.stub)
        return
    step.begin()
    if data.data_stream:
        msg = 'Cannot apply aliases to indices in data_stream'
        logger.debug(msg)
        step.add_log(msg)
        step.end(completed=True, errors=False, logmsg=f'{stepname} completed')
        return
    if not task.job.dry_run:
        msg = f'Assigning aliases {var.index} to index {var.mount_name}'
        logger.debug(msg)
        step.add_log(msg)
        try:
            api.assign_alias(var.client, var.mount_name, var.index)
        except BadClientResult as bad:
            failed_step(task, step, bad)
    else:
        msg = f'Assigning aliases {var.index} to index {var.mount_name}'
        _ = f'Dry-Run: No changes, but expected behavior: {msg}'
        logger.debug(_)
        step.add_log(_)
    step.end(completed=True, errors=False, logmsg=f'{stepname} completed')