Maidn/maidn-talos-proxmox
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

fix: fail when baked talos iso is missing

Browse source
This commit is contained in:
eding 2026-07-19 23:58:40 +02:00
parent 370dd7f29c
commit 816999a01f
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
terraform/scripts/stage_talos_image.py
View file

@ -52,11 +52,13 @@ def ensure_image(base_url, token, node, node_address, storage, image_url, filena
"url": image_url, "url": image_url,
}) })
wait_for_task(base_url, token, node, task.get("data")) wait_for_task(base_url, token, node, task.get("data"))
wait_for_storage_content(base_url, token, node, storage, source_filename) if not wait_for_storage_content(base_url, token, node, storage, source_filename):
raise RuntimeError(f"download task finished but {source_filename} was not found in {storage}")
if network_config_path: if network_config_path:
build_custom_iso(base_url, token, node_address, storage, source_filename, filename, network_config_path) build_custom_iso(base_url, token, node_address, storage, source_filename, filename, network_config_path)
wait_for_storage_content(base_url, token, node, storage, filename) if not wait_for_storage_content(base_url, token, node, storage, filename):
raise RuntimeError(f"custom Talos ISO {filename} was not found in {storage} after baking")
response = api_request(base_url, token, "GET", content_path) response = api_request(base_url, token, "GET", content_path)
for item in response.get("data", []): for item in response.get("data", []):
@ -88,9 +90,9 @@ def wait_for_storage_content(base_url, token, node, storage, filename):
for _ in range(180): for _ in range(180):
response = api_request(base_url, token, "GET", content_path) response = api_request(base_url, token, "GET", content_path)
if any(item.get("volid", "").endswith(filename) for item in response.get("data", [])): if any(item.get("volid", "").endswith(filename) for item in response.get("data", [])):
return return True
time.sleep(2) time.sleep(2)
raise RuntimeError(f"timed out waiting for {filename} to appear in {node}/{storage}") return False
def run_ssh(node_address, script): def run_ssh(node_address, script):