opensource/dify
2
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2026-04-26 02:06:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor webhook service enduser operations

Browse Source
This commit is contained in:
Yeuoly 2025-10-18 19:11:15 +08:00
parent 95aeb61d7c
commit 8a18b6e13b
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
api/services/trigger/webhook_service.py
View File

@ -12,7 +12,6 @@ from sqlalchemy.orm import Session
from werkzeug.exceptions import RequestEntityTooLarge from werkzeug.exceptions import RequestEntityTooLarge
from configs import dify_config from configs import dify_config
from controllers.service_api.wraps import get_or_create_end_user_by_type
from core.app.entities.app_invoke_entities import InvokeFrom from core.app.entities.app_invoke_entities import InvokeFrom
from core.file.models import FileTransferMethod from core.file.models import FileTransferMethod
from core.tools.tool_file_manager import ToolFileManager from core.tools.tool_file_manager import ToolFileManager
@ -25,6 +24,7 @@ from models.enums import WorkflowRunTriggeredFrom
from models.model import App from models.model import App
from models.workflow import AppTrigger, AppTriggerStatus, AppTriggerType, Workflow, WorkflowWebhookTrigger from models.workflow import AppTrigger, AppTriggerStatus, AppTriggerType, Workflow, WorkflowWebhookTrigger
from services.async_workflow_service import AsyncWorkflowService from services.async_workflow_service import AsyncWorkflowService
from services.end_user_service import EndUserService
from services.workflow.entities import TriggerData from services.workflow.entities import TriggerData
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
@ -719,7 +719,7 @@ class WebhookService:
tenant_id=webhook_trigger.tenant_id, tenant_id=webhook_trigger.tenant_id,
) )
end_user = get_or_create_end_user_by_type( end_user = EndUserService.get_or_create_end_user_by_type(
type=InvokeFrom.TRIGGER, type=InvokeFrom.TRIGGER,
tenant_id=webhook_trigger.tenant_id, tenant_id=webhook_trigger.tenant_id,
app_id=webhook_trigger.app_id, app_id=webhook_trigger.app_id,