def lambda_handler()

in assets/functions/state_topic_subscription/app.py [0:0]

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

def lambda_handler(event, context):
    glue_job_name= os.environ['glue_job_name']

    message = event['Records'][0]['Sns']['Message']
    detail = json.loads(message)['detail']

    # TODO move to SNS topic filter
    job_name = (detail['jobName'])
    job_sate = ((detail['state']))
    if job_name == glue_job_name and job_sate == 'SUCCEEDED':
        trigger_state_machine()
    else:
        print('receive job state change event: [{}][{}]'.format(job_name, job_sate))