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)}