Added error handling to find_pr script (#14110)

pull/14240/head
Roy Lenferink 2019-05-08 23:12:36 +02:00 committed by Kubernetes Prow Robot
parent 017a224473
commit de62ee2d2b
1 changed files with 35 additions and 16 deletions

View File

@ -1,6 +1,7 @@
#!/usr/bin/env python #!/usr/bin/env python
import os import os
import json
import click import click
import requests import requests
@ -25,6 +26,11 @@ def main(tags, token, path, last_n_pr):
ex: ex:
./find_pr.py --tags "language/fr" "content/fr/_index.html" ./find_pr.py --tags "language/fr" "content/fr/_index.html"
""" """
if not token:
print("GitHub token not provided (required)")
exit(1)
query = Template(""" query = Template("""
query { query {
repository(name: "website", owner: "kubernetes") { repository(name: "website", owner: "kubernetes") {
@ -47,24 +53,37 @@ def main(tags, token, path, last_n_pr):
} }
} }
""").render(tags=tags, last_n_pr=last_n_pr) """).render(tags=tags, last_n_pr=last_n_pr)
r = requests.post("https://api.github.com/graphql",
json={"query": query},
headers={
"Authorization": "token %s" % token,
"Accept": "application/vnd.github.ocelot-preview+json",
"Accept-Encoding": "gzip"
})
reply = r.json()
prs = reply['data']['repository']['pullRequests']['edges']
for pr in prs: try:
files = pr["node"]["files"]["edges"] r = requests.post("https://api.github.com/graphql",
for f in files: json={"query": query},
if path == f["node"]["path"]: headers={
print("%s (%s)" % (pr["node"]["title"], pr["node"]["state"])) "Authorization": "token %s" % token,
print(pr["node"]["url"]) "Accept": "application/vnd.github.ocelot-preview+json",
print("----------------") "Accept-Encoding": "gzip"
})
r.raise_for_status()
reply = r.json()
prs = reply['data']['repository']['pullRequests']['edges']
for pr in prs:
files = pr["node"]["files"]["edges"]
for f in files:
if path == f["node"]["path"]:
print("%s (%s)" % (pr["node"]["title"], pr["node"]["state"]))
print(pr["node"]["url"])
print("----------------")
except requests.exceptions.HTTPError as err:
gh_err_response = json.loads(err.response.text)
print("HTTP Error: %d %s" % (err.response.status_code, gh_err_response['message']))
except requests.exceptions.ConnectionError as err:
print("Error Connecting: %s" % err)
except requests.exceptions.Timeout as err:
print("Timeout Error: %s" % err)
except requests.exceptions.RequestException as err:
print("Oops, another error occurred: %s" % err)
if __name__ == '__main__': if __name__ == '__main__':
main() main()