async_task.py(全新文件:异步任务队列)
import asyncio
import json
import uuid
import os
from dotenv import load_dotenv
from memory_store import memory
from pipeline import ToolPipeline, pipeline_runner
load_dotenv()
TASK_QUEUE os.getenv(“TASK_QUEUE_KEY”)
DEAD_QUEUE os.getenv(“DEAD_QUEUE_KE…
2026/7/21 21:57:20