Infrastructure/ansible
1
0
Fork 0
Code Issues Pull requests 6 Projects Releases Packages Wiki Activity Actions

copr-backend: more insistent subscription cleanup

Browse source
This commit is contained in:
Pavel Raiskup 2022-01-19 06:51:58 +01:00
parent 72a120df85
commit 445a2ff9a5
1 changed files with 20 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

23
roles/copr/backend/templates/cleanup-unused-redhat-subscriptions
View file

@ -11,6 +11,7 @@ import os
import random import random
import subprocess import subprocess
import sys import sys
import time
import requests import requests
@ -27,6 +28,21 @@ LOG = logging.getLogger(__name__)
logging.basicConfig(level=logging.DEBUG) logging.basicConfig(level=logging.DEBUG)
def repeat_request(method, *args, **kwargs):
"""
Till there's some requests' Connection error, re-try.
"""
last_err = None
for _ in range(10):
try:
return method(*args, **kwargs)
except requests.exceptions.ConnectionError as err:
last_err = err
LOG.error("requests error: %s", str(err))
time.sleep(10)
raise last_err
def _copr_instance(): def _copr_instance():
return "{% if devel %}devel{% else %}production{% endif %}" return "{% if devel %}devel{% else %}production{% endif %}"
@ -56,7 +72,8 @@ def get_auth(url, opts):
response = None response = None
for _ in range(2): for _ in range(2):
response = requests.get(url, headers=_auth_headers(opts)) response = repeat_request(requests.get, url,
headers=_auth_headers(opts))
if response.status_code == 401: if response.status_code == 401:
get_access_token(opts) get_access_token(opts)
continue continue
@ -65,7 +82,7 @@ def get_auth(url, opts):
def delete_auth(url, opts): def delete_auth(url, opts):
""" Get, with auth header """ """ Get, with auth header """
return requests.delete(url, headers=_auth_headers(opts)) return repeat_request(requests.delete, url, headers=_auth_headers(opts))
def get_access_token(opts): def get_access_token(opts):
@ -78,7 +95,7 @@ def get_access_token(opts):
"client_id": "rhsm-api", "client_id": "rhsm-api",
"refresh_token": opts["offline_token"], "refresh_token": opts["offline_token"],
} }
resp = requests.post(URL_TOKEN, data) resp = repeat_request(requests.post, URL_TOKEN, data)
resp_data = resp.json() resp_data = resp.json()
opts["access_token"] = resp_data["access_token"] opts["access_token"] = resp_data["access_token"]