mirror of
https://github.com/timescale/timescaledb.git
synced 2025-05-16 02:23:49 +08:00
ec733de130
This patch adds a GitHub action that posts all failed CI jobs in the last 24 hours with link to the failed job.
60 lines
1.5 KiB
Python
60 lines
1.5 KiB
Python
#!/usr/bin/python3
|
|
|
|
from datetime import datetime
|
|
import requests
|
|
import json
|
|
import os
|
|
|
|
# API reference: https://docs.github.com/en/rest/reference/actions#workflow-runs
|
|
# Slack message formatting: https://api.slack.com/reference/surfaces/formatting
|
|
url = 'https://api.github.com/repos/timescale/timescaledb/actions/runs?event=schedule&status=completed'
|
|
|
|
message=list()
|
|
|
|
def get_json(url):
|
|
response = requests.get(url)
|
|
return response.json()
|
|
|
|
# get runs from last 24 hours
|
|
def process_runs(runs):
|
|
failed=list()
|
|
|
|
for run in runs:
|
|
start = datetime.strptime(run['created_at'], "%Y-%m-%dT%H:%M:%SZ")
|
|
delta = datetime.now() - start
|
|
|
|
if delta.days >= 1:
|
|
break
|
|
|
|
if run['conclusion'] != 'success':
|
|
failed.append(run)
|
|
|
|
return failed
|
|
|
|
def print_run_details(run):
|
|
job_data = get_json(run['jobs_url'])
|
|
for job in job_data['jobs']:
|
|
if job['conclusion'] != 'success':
|
|
message.append("<{html_url}|{workflow_name} {name}>".format(workflow_name=run['name'], **job))
|
|
|
|
def print_summary(failed):
|
|
if len(failed) > 0:
|
|
message.append("Failed scheduled CI runs in last 24 hours:")
|
|
for run in failed:
|
|
print_run_details(run)
|
|
else:
|
|
message.append("No failed scheduled CI runs in last 24 hours :tada:")
|
|
|
|
try:
|
|
data = get_json(url)
|
|
failed = process_runs(data['workflow_runs'])
|
|
print_summary(failed)
|
|
except json.decoder.JSONDecodeError:
|
|
message.append("Error processing GitHub response")
|
|
|
|
slack_msg=dict()
|
|
slack_msg['channel'] = os.environ['SLACK_CHANNEL']
|
|
slack_msg['text'] = "\n".join(message)
|
|
|
|
print(json.dumps(slack_msg))
|