in src/pipeline_alerts_function/app.py [0:0]
def assemble_message(event):
pipeline_event = event['detail-type']
pipeline_name = event['detail']['pipeline']['slug']
pipeline_event_finished = event['detail']['build']['finished_at']
pipeline_event_state = event['detail']['build']['state']
if pipeline_event_state == "passed":
pipeline_event_state = pipeline_event_state + " :rocket:"
if pipeline_event_state == "failed":
pipeline_event_state = pipeline_event_state + " :x:"
post_message = f"[Buildkite] {pipeline_event} for pipeline: {pipeline_name}, {pipeline_event_finished}. Status: {pipeline_event_state}"
return post_message