almalinux/pungi
15
2
Fork 0
Code Issues Pull Requests Releases Activity

Add retries to skopeo inspect calls

Browse Source 
These can fail for any transient networking reason. Let's make a few
attempts before giving up.

Signed-off-by: Lubomír Sedlář <lsedlar@redhat.com>
(cherry picked from commit 2c289729b9b24300f18ca5ca2eb1edd83da63a53)
This commit is contained in:
Lubomír Sedlář 2025-07-24 13:32:40 +02:00 committed by Stepan Oksanichenko
parent d818c781f9
commit 858c0ab252
1 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
pungi/util.py
View File

@ -281,14 +281,6 @@ class ContainerTagResolver(object):
return url.replace(tag, f"@{digest}") return url.replace(tag, f"@{digest}")
def _skopeo_inspect(url):
"""Wrapper for running `skopeo inspect {url}` and parsing the output."""
cp = subprocess.run(
["skopeo", "inspect", url], stdout=subprocess.PIPE, check=True, encoding="utf-8"
)
return json.loads(cp.stdout)
# format: {arch|*: [data]} # format: {arch|*: [data]}
def get_arch_data(conf, var_name, arch): def get_arch_data(conf, var_name, arch):
result = [] result = []
@ -1081,3 +1073,14 @@ def format_size(sz):
unit += 1 unit += 1
return "%.3g %sB" % (sz, UNITS[unit]) return "%.3g %sB" % (sz, UNITS[unit])
@retry(interval=60, timeout=300, wait_on=RuntimeError)
def _skopeo_inspect(url):
"""Wrapper for running `skopeo inspect {url}` and parsing the output.
Retries on failure.
"""
cp = subprocess.run(
["skopeo", "inspect", url], stdout=subprocess.PIPE, check=True, encoding="utf-8"
)
return json.loads(cp.stdout)