Fix:bug fix (#12423)

### What problem does this PR solve?
change: 
initialize webhook configuration in webhook function
remove debug print statement from airtable_connector
remove redundant uuid import in imap_connector

### Type of change

- [x] Bug Fix (non-breaking change which fixes an issue)
This commit is contained in:
buua436
2026-01-04 19:16:29 +08:00
committed by GitHub
parent a8a060676a
commit 932496a8ec
3 changed files with 2 additions and 2 deletions

View File

@ -162,6 +162,7 @@ async def webhook(agent_id: str):
return get_data_error_result(code=RetCode.BAD_REQUEST,message="Invalid DSL format."),RetCode.BAD_REQUEST return get_data_error_result(code=RetCode.BAD_REQUEST,message="Invalid DSL format."),RetCode.BAD_REQUEST
# 4. Check webhook configuration in DSL # 4. Check webhook configuration in DSL
webhook_cfg = {}
components = dsl.get("components", {}) components = dsl.get("components", {})
for k, _ in components.items(): for k, _ in components.items():
cpn_obj = components[k]["obj"] cpn_obj = components[k]["obj"]

View File

@ -75,7 +75,6 @@ class AirtableConnector(LoadConnector, PollConnector):
batch: list[Document] = [] batch: list[Document] = []
for record in records: for record in records:
print(record)
record_id = record.get("id") record_id = record.get("id")
fields = record.get("fields", {}) fields = record.get("fields", {})
created_time = record.get("createdTime") created_time = record.get("createdTime")

View File

@ -12,6 +12,7 @@ from email.utils import collapse_rfc2231_value, parseaddr
from enum import Enum from enum import Enum
from typing import Any from typing import Any
from typing import cast from typing import cast
import uuid
import bs4 import bs4
from pydantic import BaseModel from pydantic import BaseModel
@ -635,7 +636,6 @@ def _parse_singular_addr(raw_header: str) -> tuple[str, str]:
if __name__ == "__main__": if __name__ == "__main__":
import time import time
import uuid
from types import TracebackType from types import TracebackType
from common.data_source.utils import load_all_docs_from_checkpoint_connector from common.data_source.utils import load_all_docs_from_checkpoint_connector