Skip to content
Merged
Show file tree
Hide file tree
Changes from 3 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions ex_app/lib/all_tools/lib/task_processing.py
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,9 @@
import asyncio
import typing

from niquests import ConnectionError, Timeout
from nc_py_api import AsyncNextcloudApp, NextcloudException
from nc_py_api.ex_app import LogLvl
from niquests import ConnectionError, Timeout
from pydantic import BaseModel, ValidationError

from ex_app.lib.logger import log
Expand Down Expand Up @@ -75,7 +75,7 @@ async def run_task(nc: AsyncNextcloudApp, type, task_input):
if task.status != "STATUS_SUCCESSFUL":
raise Exception("Nextcloud TaskProcessing Task failed")

if not isinstance(task.output, dict) or all(x not in ["file", "output", "images", "slide_deck"] for x in task.output):
if not isinstance(task.output, dict) or all(x not in ["file", "output", "images", "slide_deck", "sources"] for x in task.output):
raise Exception('"output" key not found in Nextcloud TaskProcessing task result')
Comment thread
kyteinsky marked this conversation as resolved.
Outdated

return task
Loading
Loading