youngkingdom/dify
1
0
Fork 0
mirror of https://github.com/langgenius/dify.git synced 2026-03-23 07:17:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat(trigger): enhance trigger handling with new data validation and logging improvements

Browse Source 
- Added validation for `PluginTriggerData` and `ScheduleTriggerData` in the `WorkflowService` to support new trigger types.
- Updated debug event return strings in `PluginTriggerDebugEvent` and `WebhookDebugEvent` for clarity and consistency.
- Enhanced logging in `dispatch_triggered_workflows_async` to include subscription and provider IDs, improving traceability during trigger dispatching.
This commit is contained in:
Harry
2025-10-14 14:36:40 +08:00
parent bf42386c5b
commit 6773dda657
3 changed files with 25 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
api/tasks/trigger_processing_tasks.py
View File

@ -58,11 +58,12 @@ def dispatch_triggered_workflows_async(
try:
logger.info(
"Starting async trigger dispatching for endpoint=%s, events=%s, request_id=%s, timestamp=%s",
"Starting trigger dispatching endpoint=%s, events=%s, request_id=%s, subscription_id=%s, provider_id=%s",
endpoint_id,
events,
request_id,
timestamp,
subscription_id,
provider_id,
)
# Verify request exists in storage
@ -155,14 +156,25 @@ def dispatch_triggered_workflows_async(
event=event,
pool_key=pool_key,
)
logger.debug(
"Trigger debug dispatched %d sessions to pool %s for event %s for subscription %s provider %s",
debug_dispatched,
pool_key,
event_name,
subscription_id,
provider_id,
)
except Exception:
# Silent failure for debug dispatch
logger.exception("Failed to dispatch to debug sessions")
logger.info(
"Completed async trigger dispatching: processed %d/%d triggers",
"Completed async trigger dispatching: processed %d/%d triggers for subscription %s and provider %s",
dispatched_count,
len(events),
subscription_id,
provider_id,
)
return {
@ -174,9 +186,11 @@ def dispatch_triggered_workflows_async(
except Exception as e:
logger.exception(
"Error in async trigger dispatching for endpoint %s data %s",
"Error in async trigger dispatching for endpoint %s data %s for subscription %s and provider %s",
endpoint_id,
dispatch_data,
subscription_id,
provider_id,
)
return {
"status": "failed",