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 4a6342d commit 8577767Copy full SHA for 8577767
runpod/serverless/modules/rp_job.py
@@ -155,7 +155,7 @@ async def run_job_generator(
155
'''
156
try:
157
job_output = handler(job)
158
- for output_partial in job_output:
+ async for output_partial in job_output:
159
yield {"output": output_partial}
160
except Exception as err: # pylint: disable=broad-except
161
log.error(f'Error while running job {job["id"]}: {err}')
0 commit comments