Skip to content

Commit 631be1a

Browse files
author
Andrei Neagu
committed
refactor
1 parent ee36743 commit 631be1a

File tree

1 file changed

+4
-5
lines changed

1 file changed

+4
-5
lines changed

packages/service-library/src/servicelib/fastapi/long_running_tasks/_context_manager.py

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -104,17 +104,16 @@ async def _status_update() -> TaskStatus:
104104
)
105105
return task_status
106106

107-
async def _wait_task_completion() -> None:
107+
async def _wait_for_task_result() -> Any:
108108
task_status = await _status_update()
109109
while not task_status.done:
110110
await asyncio.sleep(status_poll_interval)
111111
task_status = await _status_update()
112112

113-
try:
114-
await asyncio.wait_for(_wait_task_completion(), timeout=task_timeout)
115-
116-
result = await client.get_task_result(task_id)
113+
return await client.get_task_result(task_id)
117114

115+
try:
116+
result = await asyncio.wait_for(_wait_for_task_result(), timeout=task_timeout)
118117
logger.debug("%s, %s", f"{task_id=}", f"{result=}")
119118

120119
yield result

0 commit comments

Comments
 (0)