Skip to content

Commit cb55431

Browse files
koryakraftp
andauthored
fix(client): Await for a coroutine in retrieve_workflow_async() (#449)
It seems that an await statement was accidentally forgotten in `retrieve_workflow_async()`. This PR fixes it. Co-authored-by: Peter Kraft <[email protected]>
1 parent ad4fa69 commit cb55431

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

dbos/_client.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -241,7 +241,7 @@ def retrieve_workflow(self, workflow_id: str) -> WorkflowHandle[R]:
241241
return WorkflowHandleClientPolling[R](workflow_id, self._sys_db)
242242

243243
async def retrieve_workflow_async(self, workflow_id: str) -> WorkflowHandleAsync[R]:
244-
status = asyncio.to_thread(get_workflow, self._sys_db, workflow_id)
244+
status = await asyncio.to_thread(get_workflow, self._sys_db, workflow_id)
245245
if status is None:
246246
raise DBOSNonExistentWorkflowError(workflow_id)
247247
return WorkflowHandleClientAsyncPolling[R](workflow_id, self._sys_db)

0 commit comments

Comments
 (0)