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

comms: retry room leave actions

Browse Source
This commit is contained in:
Brad Stein 2026-01-08 04:32:05 -03:00
parent 31ca499c04
commit 7860003f15
1 changed files with 21 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
services/comms/bstein-force-leave-job.yaml
View File

@ -2,7 +2,7 @@
apiVersion: batch/v1 apiVersion: batch/v1
kind: Job kind: Job
metadata: metadata:
name: bstein-leave-rooms-3 name: bstein-leave-rooms-4
namespace: comms namespace: comms
spec: spec:
backoffLimit: 0 backoffLimit: 0
@ -150,6 +150,9 @@ spec:
try: try:
for room_id in TARGET_ROOMS: for room_id in TARGET_ROOMS:
room_q = urllib.parse.quote(room_id, safe="") room_q = urllib.parse.quote(room_id, safe="")
leave_status = 0
forget_status = 0
for attempt in range(1, 6):
leave_status, _ = http_json( leave_status, _ = http_json(
"POST", "POST",
f"{SYNAPSE_BASE}/_matrix/client/v3/rooms/{room_q}/leave", f"{SYNAPSE_BASE}/_matrix/client/v3/rooms/{room_q}/leave",
@ -164,6 +167,9 @@ spec:
json_body={}, json_body={},
timeout=30, timeout=30,
) )
if leave_status == 200 and forget_status == 200:
break
time.sleep(attempt * 2)
results["rooms"][room_id] = {"leave": leave_status, "forget": forget_status} results["rooms"][room_id] = {"leave": leave_status, "forget": forget_status}
if leave_status != 200 or forget_status != 200: if leave_status != 200 or forget_status != 200:
failures.append(room_id) failures.append(room_id)