def lambda_handler()

in lambda/sfn_trigger/handler.py [0:0]

• 27 lines of code
• 6 McCabe index (conditional complexity)

def lambda_handler(event, context):

    print(event)

    s3_objects = [
        {
            "bucket": event_record["s3"]["bucket"]["name"],
            "key": event_record["s3"]["object"]["key"],
        }
        for event_record in event["Records"]
        if event_record["s3"] and "tar.gz" in event_record["s3"]["object"]["key"]
    ]

    if s3_objects:
        for record in s3_objects:

            bucket = record["bucket"]
            key = record["key"]
            model_path = f"s3://{bucket}/{key}"

            current_time = datetime.now().strftime("%Y-%m-%d-%H-%M")

            sfn_inputs = {
                "Comment": "Automatically triggered by S3 put item event",
                "model_path": model_path,
                "job_name": f"xgboost-{current_time}",
                "wait_seconds": WAIT_SECONDS,
            }

            _ = sfn_client.start_execution(
                stateMachineArn=STATE_MACHINE_ARN,
                name=current_time,
                input=json.dumps(sfn_inputs),
            )