Skip to content

Commit 7fb7919

Browse files
authored
Merge pull request #709 from atlanhq/APP-8346
APP-8346 Fix problem in async iterator in AsyncWorkflowSearchResponse
2 parents 5caac46 + acf38aa commit 7fb7919

2 files changed

Lines changed: 3 additions & 1 deletion

File tree

pyatlan/client/aio/workflow.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -243,7 +243,7 @@ async def _find_runs(
243243
return AsyncWorkflowSearchResponse(
244244
client=self._client,
245245
endpoint=endpoint,
246-
criteria=request_obj,
246+
criteria=query,
247247
start=from_,
248248
size=size,
249249
**sync_response,

tests/integration/aio/test_workflow_client.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -191,6 +191,8 @@ async def test_workflow_get_runs_and_stop(
191191
[AtlanWorkflowPhase.FAILED], started_at="now-1h"
192192
)
193193
assert runs_status
194+
async for _ in runs_status:
195+
pass
194196

195197

196198
async def test_workflow_get_all_scheduled_runs(

0 commit comments

Comments
 (0)