diff --git a/api/services/trigger/trigger_subscription_builder_service.py b/api/services/trigger/trigger_subscription_builder_service.py index 8e57996812..5c71dc7aa2 100644 --- a/api/services/trigger/trigger_subscription_builder_service.py +++ b/api/services/trigger/trigger_subscription_builder_service.py @@ -297,15 +297,20 @@ class TriggerSubscriptionBuilderService: controller: PluginTriggerProviderController = TriggerManager.get_trigger_provider( tenant_id=subscription_builder.tenant_id, provider_id=TriggerProviderID(subscription_builder.provider_id) ) - response: TriggerDispatchResponse = controller.dispatch( - user_id=subscription_builder.user_id, - request=request, - subscription=subscription_builder.to_subscription(), - credentials={}, - credential_type=CredentialType.UNAUTHORIZED, - ) + try: + response: TriggerDispatchResponse = controller.dispatch( + user_id=subscription_builder.user_id, + request=request, + subscription=subscription_builder.to_subscription(), + credentials={}, + credential_type=CredentialType.UNAUTHORIZED, + ) + except Exception as e: + error_response = Response(status=500, response=str(e)) + cls.append_log(endpoint_id=endpoint_id, request=request, response=error_response) + return error_response # append the request log - cls.append_log(endpoint_id, request, response.response) + cls.append_log(endpoint_id=endpoint_id, request=request, response=response.response) return response.response @classmethod