From c5c0214e806ec6c0445d061db42f0775f69e65df Mon Sep 17 00:00:00 2001 From: genekogan Date: Tue, 7 Jan 2025 01:59:26 -0800 Subject: [PATCH] fix changestream --- eve/tools/comfyui_tool.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/eve/tools/comfyui_tool.py b/eve/tools/comfyui_tool.py index 7af69e9..98beec6 100644 --- a/eve/tools/comfyui_tool.py +++ b/eve/tools/comfyui_tool.py @@ -3,7 +3,6 @@ from bson import ObjectId from pydantic import BaseModel, Field from typing import List, Optional, Dict -import asyncio from ..mongo import get_collection from ..tool import Tool @@ -132,6 +131,8 @@ def convert_tasks2_to_tasks3(): with tasks2.watch(pipeline) as stream: for change in stream: task_id = change["documentKey"]["_id"] + if "updateDescription" not in change: + continue update = change["updateDescription"]["updatedFields"] task = Task.from_mongo(task_id) task.reload()