def start_kda_app()

in custom-resource/lambda_function.py [0:0]

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

def start_kda_app(event):
    try:
        application_name = event['ResourceProperties']['ApplicationName']
        application_status = kinesis_analytics.describe_application(
            ApplicationName = application_name
        )
        if(application_status['ApplicationDetail']['ApplicationStatus'] == 'READY'):
            print('Application is ready, starting...')
            response = kinesis_analytics.start_application(
                ApplicationName = application_name,
                InputConfigurations = [
                    {
                        'Id': '1.1',
                        'InputStartingPositionConfiguration': {
                            'InputStartingPosition': 'NOW'
                        }
                    }
                ]
            )
        else:
            print('KDA app is not ready, current status is {}'.format(application_status['ApplicationDetail']['ApplicationStatus']))
    except Exception as e:
        print(e)
        helper.init_failure(e)