def assemble_message()

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