StealthOS/subiquity
StealthOS
/
subiquity
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add a way to annotate the result of a asynchronous snapd operation

This commit is contained in:
Michael Hudson-Doyle 2024-05-03 17:23:53 +12:00
parent b53c1fffb7
commit 5605942e70
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
subiquity/server/snapdapi.py
View File

@ -313,14 +313,17 @@ def make_api_client(async_snapd):
snapd_serializer = Serializer(ignore_unknown_fields=True, serialize_enums_by="value")
async def post_and_wait(client, meth, *args, **kw):
async def post_and_wait(client, meth, *args, ann=None, **kw):
change_id = await meth(*args, **kw)
log.debug("post_and_wait %s", change_id)
while True:
result = await client.v2.changes[change_id].GET()
if result.status == TaskStatus.DONE:
return result.data
data = result.data
if ann is not None:
data = snapd_serializer.deserialize(ann, data)
return data
elif result.status == TaskStatus.ERROR:
raise aiohttp.ClientError(result.err)
await asyncio.sleep(0.1)