def lambda_handler()

in lambda/build/lambda_start_pipeline.py [0:0]


def lambda_handler(event, context):
    logger.debug(json.dumps(event))
    job_id = event["CodePipeline.job"]["id"]
    job_data = event["CodePipeline.job"]["data"]
    user_parameters = job_data["actionConfiguration"]["configuration"]["UserParameters"]
    pipeline_name = json.loads(user_parameters)["PipelineName"]
    pipeline_execution_arn = None
    if "continuationToken" in job_data:
        pipeline_execution_arn = job_data["continuationToken"]
    status_code, result = check_pipeline(job_id, pipeline_name, pipeline_execution_arn)
    logger.debug(json.dumps(result))
    return {"statusCode": status_code, "body": json.dumps(result)}