Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
24 changes: 5 additions & 19 deletions apps/trigger/handler/impl/task/tool_task.py
Original file line number Diff line number Diff line change
Expand Up @@ -35,24 +35,10 @@ def get_field_value(value, kwargs):
return get_reference(value.get('value'), kwargs)


def get_application_execute_parameters(parameter_setting, kwargs):
parameters = {'form_data': {}}
question_setting = parameter_setting.get('question')
if question_setting:
parameters['message'] = get_field_value(question_setting, kwargs)
filed_list = ['image_list', 'document_list', 'audio_list', 'video_list', 'other_list']
for field in filed_list:
field_setting = parameter_setting.get(field)
if field_setting:
parameters[field] = get_field_value(field_setting, kwargs)
api_input_field_list = parameter_setting.get('api_input_field_list')
if api_input_field_list:
for key, value in api_input_field_list.items():
parameters['form_data'][key] = get_field_value(value, kwargs)
user_input_field_list = parameter_setting.get('user_input_field_list')
if user_input_field_list:
for key, value in user_input_field_list.items():
parameters['form_data'][key] = get_field_value(value, kwargs)
def get_tool_execute_parameters(parameter_setting, kwargs):
parameters = {}
for key, value in parameter_setting.items():
parameters[key] = get_field_value(value, kwargs)
return parameters


Expand Down Expand Up @@ -81,7 +67,7 @@ def support(self, trigger_task, **kwargs):

def execute(self, trigger_task, **kwargs):
parameter_setting = trigger_task.get('parameter')
parameters = get_application_execute_parameters(parameter_setting, kwargs)
parameters = get_tool_execute_parameters(parameter_setting, kwargs)
tool_id = trigger_task.get('source_id')
task_record_id = uuid.uuid7()

Expand Down
3 changes: 2 additions & 1 deletion apps/trigger/handler/simple_tools.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,10 +9,11 @@
from threading import Thread

from trigger.handler.impl.task.application_task import ApplicationTask
from trigger.handler.impl.task.tool_task import ToolTask
from trigger.handler.impl.trigger.event_trigger import EventTrigger
from trigger.handler.impl.trigger.scheduled_trigger import ScheduledTrigger

simple_task_handlers = [ApplicationTask()]
simple_task_handlers = [ApplicationTask(), ToolTask()]

simple_trigger_handlers = [ScheduledTrigger(), EventTrigger()]

Expand Down
4 changes: 3 additions & 1 deletion apps/trigger/sql/get_trigger_task_record_page_list.sql
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,10 @@ WITH source_data_cte AS (SELECT 'APPLICATION' as source_type,
"folder_id"
FROM tool)
select ett.*,
ett.meta::json as meta,
sdc.name as source_name,
sdc.icon as source_icon
sdc.icon as source_icon,
sdc.type as type
from event_trigger_task_record ett
left join source_data_cte sdc
on ett.source_id = sdc.id and ett.source_type = sdc.source_type