def download_sources()

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

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

def download_sources(event, context):
    url = os.environ['url']
    bucket = os.environ['bucket']
    key = os.environ['key']

    try:
        if event['RequestType'] != 'Delete':
            req = urllib.request.Request(url)
            response = urllib.request.urlopen(req)

            s3client.put_object(Bucket=bucket, Key=key, Body=response.read())

        cfnresponse.send(event, context, cfnresponse.SUCCESS, {})
    except Exception:
        traceback.print_exc()

        cfnresponse.send(event, context, cfnresponse.FAILED, {})