diff --git a/core/workflow.py b/core/workflow.py index 495700a..15c3cdd 100755 --- a/core/workflow.py +++ b/core/workflow.py @@ -6,7 +6,8 @@ - 图片AI接入点:调用 workflow.image_ai_submit_result(task_id, result_url) - 消息回调接口:通过 register_send_callback 注入发送函数 """ -import asyncio`r`nimport logging +import asyncio +import logging import os import uuid from enum import Enum @@ -14,7 +15,8 @@ from typing import Optional, Dict, Callable, Awaitable, Any, List from datetime import datetime from dataclasses import dataclass, field -_WECHAT_WEBHOOK = os.getenv("WECHAT_WEBHOOK", "")`r`nlogger = logging.getLogger("cs_agent") +_WECHAT_WEBHOOK = os.getenv("WECHAT_WEBHOOK", "") +logger = logging.getLogger("cs_agent") async def _wechat_notify(content: str):