def notify_build_success()

in resources/flink-on-kda/cdk/lambda/build-pipeline-helper.py [0:0]

• 12 lines of code
• 2 McCabe index (conditional complexity)

def notify_build_success(event, context):
    job_id = event['CodePipeline.job']['id']

    url = os.environ['waitHandleUrl']
    headers = { "Content-Type": "" }
    data = { "Status": "SUCCESS", "Reason": "Compilation Succeeded", "UniqueId": job_id, "Data": "Compilation Succeeded" }

    try:
        req = urllib.request.Request(url, headers=headers, data=bytes(json.dumps(data), encoding="utf-8"), method='PUT')
        response = urllib.request.urlopen(req)

        code_pipeline.put_job_success_result(jobId=job_id)
    except Exception:
        traceback.print_exc()

        code_pipeline.put_job_failure_result(jobId=job_id, failureDetails={'type': 'JobFailed'})