bstein/titan-iac
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

comms: retry guest rename when MAS restarts

Browse Source
This commit is contained in:
Brad Stein 2026-01-08 02:00:52 -03:00
parent 9a76680cc4
commit 3aa36e87b8
1 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
services/comms/guest-name-job.yaml
View File

@ -51,6 +51,7 @@ spec:
import os import os
import random import random
import requests import requests
import time
import urllib.parse import urllib.parse
ADJ = [ ADJ = [
@ -76,14 +77,21 @@ spec:
with open(MAS_ADMIN_CLIENT_SECRET_FILE, "r", encoding="utf-8") as f: with open(MAS_ADMIN_CLIENT_SECRET_FILE, "r", encoding="utf-8") as f:
secret = f.read().strip() secret = f.read().strip()
basic = base64.b64encode(f"{MAS_ADMIN_CLIENT_ID}:{secret}".encode()).decode() basic = base64.b64encode(f"{MAS_ADMIN_CLIENT_ID}:{secret}".encode()).decode()
r = requests.post( last_err = None
MAS_TOKEN_URL, for attempt in range(5):
headers={"Authorization": f"Basic {basic}"}, try:
data={"grant_type": "client_credentials", "scope": "urn:mas:admin"}, r = requests.post(
timeout=30, MAS_TOKEN_URL,
) headers={"Authorization": f"Basic {basic}"},
r.raise_for_status() data={"grant_type": "client_credentials", "scope": "urn:mas:admin"},
return r.json()["access_token"] timeout=30,
)
r.raise_for_status()
return r.json()["access_token"]
except Exception as exc: # noqa: BLE001
last_err = exc
time.sleep(2 ** attempt)
raise last_err
def mas_user_id(token, username): def mas_user_id(token, username):
r = requests.get( r = requests.get(