We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bc92fe5 commit ade778aCopy full SHA for ade778a
workflowai/core/client/client.py
@@ -140,7 +140,7 @@ async def run(
140
res = None
141
delay = retry_delay / 1000
142
retry_count = 0
143
- while retry_count <= max_retry_count:
+ while retry_count < max_retry_count:
144
try:
145
res = await self.api.post(route, request, returns=TaskRunResponse)
146
return res.to_domain(task)
@@ -169,7 +169,7 @@ async def run(
169
async def _stream():
170
171
172
173
174
async for chunk in self.api.stream(
175
method="POST", path=route, data=request, returns=RunTaskStreamChunk
0 commit comments