Fix APP-8346

ErnestoLoma · ErnestoLoma · commit 394230384ef7 · 2025-08-27T10:51:53.000-06:00
diff --git a/pyatlan/model/aio/workflow.py b/pyatlan/model/aio/workflow.py
@@ -66,7 +66,7 @@ async def next_page(self, start=None, size=None) -> bool:
     async def _get_next_page(self) -> bool:
         """Fetch the next page of results."""
         request = WorkflowSearchRequest(
-            query=self._criteria, from_=self._start, size=self._size
+            query=self._criteria.query, from_=self._start, size=self._size
         )
         raw_json = await self._client._call_api(
             api=self._endpoint,
diff --git a/tests/integration/aio/test_workflow_client.py b/tests/integration/aio/test_workflow_client.py
@@ -191,6 +191,8 @@ async def test_workflow_get_runs_and_stop(
         [AtlanWorkflowPhase.FAILED], started_at="now-1h"
     )
     assert runs_status
+    async for _ in runs_status:
+        pass
 
 
 async def test_workflow_get_all_scheduled_runs(

Original file line number	Diff line number	Diff line change
`@@ -66,7 +66,7 @@ async def next_page(self, start=None, size=None) -> bool:`
`66`	`66`	`async def _get_next_page(self) -> bool:`
`67`	`67`	`"""Fetch the next page of results."""`
`68`	`68`	`request = WorkflowSearchRequest(`
`69`		`- query=self._criteria, from_=self._start, size=self._size`
	`69`	`+ query=self._criteria.query, from_=self._start, size=self._size`
`70`	`70`	`)`
`71`	`71`	`raw_json = await self._client._call_api(`
`72`	`72`	`api=self._endpoint,`
Original file line number	Diff line number	Diff line change
`@@ -191,6 +191,8 @@ async def test_workflow_get_runs_and_stop(`
`191`	`191`	`[AtlanWorkflowPhase.FAILED], started_at="now-1h"`
`192`	`192`	`)`
`193`	`193`	`assert runs_status`
	`194`	`+ async for _ in runs_status:`
	`195`	`+ pass`
`194`	`196`
`195`	`197`
`196`	`198`	`async def test_workflow_get_all_scheduled_runs(`