diff --git a/api/apps/sdk/agents.py b/api/apps/sdk/agents.py index e6a687869..cac561def 100644 --- a/api/apps/sdk/agents.py +++ b/api/apps/sdk/agents.py @@ -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 # 4. Check webhook configuration in DSL + webhook_cfg = {} components = dsl.get("components", {}) for k, _ in components.items(): cpn_obj = components[k]["obj"] diff --git a/common/data_source/airtable_connector.py b/common/data_source/airtable_connector.py index 6f0b5a930..46dcf07ee 100644 --- a/common/data_source/airtable_connector.py +++ b/common/data_source/airtable_connector.py @@ -75,7 +75,6 @@ class AirtableConnector(LoadConnector, PollConnector): batch: list[Document] = [] for record in records: - print(record) record_id = record.get("id") fields = record.get("fields", {}) created_time = record.get("createdTime") diff --git a/common/data_source/imap_connector.py b/common/data_source/imap_connector.py index f3371ee24..acaba7e01 100644 --- a/common/data_source/imap_connector.py +++ b/common/data_source/imap_connector.py @@ -12,6 +12,7 @@ from email.utils import collapse_rfc2231_value, parseaddr from enum import Enum from typing import Any from typing import cast +import uuid import bs4 from pydantic import BaseModel @@ -635,7 +636,6 @@ def _parse_singular_addr(raw_header: str) -> tuple[str, str]: if __name__ == "__main__": import time - import uuid from types import TracebackType from common.data_source.utils import load_all_docs_from_checkpoint_connector