def process_migration_list()

in Assets_as_Code/Assets_as_Code/src/functions.py [0:0]

• 44 lines of code
• 16 McCabe index (conditional complexity)

def process_migration_list(migrate_p, list, dev_config):
    source_migrate_list = []
    dataset_migrate_list = []
    source_session = s_func._assume_role(dev_config["aws_account_number"], dev_config["role_name"],
                                         dev_config["aws_region"])
    if migrate_p in ['dashboard']:
        for dashboard in list:
            print(dashboard)
            datasources = data_sources_ls_of_dashboard(dashboard, source_session)
            print(datasources)
            for datasource in datasources:
                source_migrate_list.append(datasource)
            datasets = data_sets_ls_of_dashboard(dashboard, source_session)
            print(datasets)
            for dataset in datasets:
                dataset_migrate_list.append(dataset)

    if migrate_p in ['analysis']:
        for analysis_name in list:
            print(analysis_name)
            datasources = data_sources_ls_of_analysis(analysis_name, sourcesession)
            print(datasources)
            for datasource in datasources:
                source_migrate_list.append(datasource)
            datasets = data_sets_ls_of_analysis(analysis_name, sourcesession)
            print(datasets)
            for dataset in datasets:
                dataset_migrate_list.append(dataset)

    if migrate_p in ['all']:
        for dashboard in list:
            datasources = data_sources_ls_of_dashboard(dashboard, sourcesession)
            for datasource in datasources:
                source_migrate_list.append(datasource)
            datasets = data_sets_ls_of_dashboard(dashboard, sourcesession)
            for dataset in datasets:
                dataset_migrate_list.append(dataset)

        for analysis_name in list:
            datasources = data_sources_ls_of_analysis(analysis_name, sourcesession)
            for datasource in datasources:
                source_migrate_list.append(datasource)
            datasets = data_sets_ls_of_analysis(analysis_name, sourcesession)
            for dataset in datasets:
                dataset_migrate_list.append(dataset)
    results = {"source_migrate_list": source_migrate_list, "dataset_migrate_list": dataset_migrate_list}
    return results