in src/cp_helper.py [0:0]
def put_job_failure(job_id, message, session=None):
"""Puts job failure to a pipeline by job_id and with message
Args:
job_id (str): Job ID from the pipeline
message (str): Message to log for the job failure
session (object, optional): boto3 session object
Returns:
None
"""
logger.info('Putting job failure...')
logger.info(message)
client = boto3_client(service='codepipeline', session=session)
client.put_job_failure_result(
jobId=job_id,
failureDetails={'message': message, 'type': 'JobFailed'}
)