workflow run streaming (#791)
This commit is contained in:
@@ -89,6 +89,8 @@ async def task_stream(
|
|||||||
|
|
||||||
if task.status == TaskStatus.running:
|
if task.status == TaskStatus.running:
|
||||||
file_name = f"{task_id}.png"
|
file_name = f"{task_id}.png"
|
||||||
|
if task.workflow_run_id:
|
||||||
|
file_name = f"{task.workflow_run_id}.png"
|
||||||
screenshot = await app.STORAGE.get_streaming_file(organization_id, file_name)
|
screenshot = await app.STORAGE.get_streaming_file(organization_id, file_name)
|
||||||
if screenshot:
|
if screenshot:
|
||||||
encoded_screenshot = base64.b64encode(screenshot).decode("utf-8")
|
encoded_screenshot = base64.b64encode(screenshot).decode("utf-8")
|
||||||
|
|||||||
Reference in New Issue
Block a user