Skip to content

Commit d5f7b3f

Browse files
committed
fix: refactor trigger task execution to use instance methods
1 parent 83ebae3 commit d5f7b3f

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

apps/trigger/handler/impl/trigger/scheduled_trigger.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -234,7 +234,7 @@ class ScheduledTrigger(BaseTrigger):
234234

235235
@staticmethod
236236
def execute(trigger, **kwargs):
237-
trigger_task = kwargs.get("trigger_task")
237+
trigger_task = kwargs.pop("trigger_task", None)
238238
if not trigger_task:
239239
maxkb_logger.warning(f"unsupported task={trigger_task}")
240240
return
@@ -243,11 +243,11 @@ def execute(trigger, **kwargs):
243243
if source_type == "APPLICATION":
244244
from trigger.handler.impl.task.application_task import ApplicationTask
245245

246-
ApplicationTask.execute(trigger_task, **kwargs)
246+
ApplicationTask().execute(trigger_task, **kwargs)
247247
elif source_type == "TOOL":
248248
from trigger.handler.impl.task.tool_task import ToolTask
249249

250-
ToolTask.execute(trigger_task, **kwargs)
250+
ToolTask().execute(trigger_task, **kwargs)
251251
else:
252252
maxkb_logger.warning(f"unsupported source_type={source_type}, task_id={trigger_task['id']}")
253253

0 commit comments

Comments
 (0)