def convert_regional_to_global()

in global-clusters-automation/add_secondarycluster.py [0:0]

• 40 lines of code
• 9 McCabe index (conditional complexity)

def convert_regional_to_global(primary_cluster_arn, global_cluster_id, secondary_clusters):
    try:
        start_time = time.time()
        primary_cluster_id = primary_cluster_arn.split(":")[-1]
        region = primary_cluster_arn.split(":")[3]
        client_local = session.client('docdb', region_name=region)
        instance_class = ""
        # Identify the instance class of the primary cluster and use the same for secondary clusters.
        while not instance_class:
            print('Checking for instance class for primary cluster ', primary_cluster_id, ' ...')
            instance_class = identify_instance_class(primary_cluster_id, client_local)
            time.sleep(1)
        print('Instance class for the current primary cluster is ', instance_class)
        cluster_status = ""
        while cluster_status != 'available':
            print('Checking for cluster and instance status before converting to global cluster...')
            cluster_status = get_cluster_status(primary_cluster_arn)
            time.sleep(1)

        # Start the conversion process by converting the regional cluster indicated by the primary cluster ARN to a
        # global cluster.
        print('Cluster and instances for primary cluster ', primary_cluster_arn, ' is in available status. '
                                                                                 'Start conversion process')
        print('Begin STEP 1 of 2 in convert to global cluster: Create global cluster ', global_cluster_id)
        print('Converting primary cluster ', primary_cluster_arn, ' to global cluster ', global_cluster_id)
        create_global_cluster(global_cluster_id, primary_cluster_arn)
        print('Created global cluster with id ', global_cluster_id)
        current_time = time.time()
        print('Completed STEP 1 of 2 in convert to global cluster process in ', current_time - start_time, ' seconds')
        # For each secondary clusters in input, add the cluster as a region to the global cluster created above.
        print('Begin STEP 2 of 2 in convert to global cluster: Create Secondary Clusters')
        for each_item in secondary_clusters:
            client_local = session.client('docdb', region_name=each_item['region'])
            create_secondary_cluster(each_item, global_cluster_id, client_local)
            print('Created secondary cluster with id ', each_item['secondary_cluster_id'])
            # For each secondary cluster in the global cluster, add instances as indicated in the input and use
            # instance class identified earlier from primary
            for instance_count in range(0, each_item['number_of_instances']):
                add_instance_to_cluster(each_item, instance_class, instance_count, client_local)
                print('Created instance ', each_item['secondary_cluster_id'] + str(instance_count),
                      'for secondary cluster ', each_item['secondary_cluster_id'])
        current_time = time.time()
        print('Completed STEP 2 of 2 in convert to global cluster process in ', current_time - start_time, ' seconds')
    except ClientError as e:
        print('ERROR OCCURRED WHILE PROCESSING: ', e)
        print('PROCESSING WILL STOP')
        raise ClientError