def get_scaling_policies()

in resources/flink-on-kda/index.py [0:0]

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

def get_scaling_policies(context):
    try:
        resource_id = get_resource_id(context)
        response = client_aas.describe_scaling_policies(
            PolicyNames=[
                'KDAScaleIn',
                'KDAScaleOut'
                ],
            ServiceNamespace='custom-resource',
            ResourceId=resource_id,
            ScalableDimension='custom-resource:ResourceType:Property',
            MaxResults=2)
        scaling_policies = response['ScalingPolicies']
        if len(scaling_policies) == 2:
            print("Found 2 scaling policies as expected")

            response = {
                scaling_policies[0]['PolicyName']: scaling_policies[0]['PolicyARN'],
                scaling_policies[1]['PolicyName']: scaling_policies[1]['PolicyARN']
            }
            
            print(response)
            
            return response
        else:
            print("Found " + str(len(scaling_policies)) + " scaling policies")
            return None
    except Exception as e:
        print("ERROR - Exception in get_scaling_policies")
        print(e)
        return None