in src/cp_helper.py [0:0]
def put_job_success(job_id, message, session=None):
"""Puts job success to a pipeline by job_id and logs message to cloudwatch
Args:
job_id (str): Job ID from the pipeline
message (str): Message to log for the job success
session (object, optional): boto3 session object
Returns:
None
"""
logger.info('Putting job success...')
logger.info(message)
client = boto3_client(service='codepipeline', session=session)
client.put_job_success_result(jobId=job_id)