执行触发器任务 @param trigger_task: 触发器任务数据 @param kwargs: 额外数据 @return:
(trigger_task, **kwargs)
| 19 | |
| 20 | |
| 21 | def execute(trigger_task, **kwargs): |
| 22 | """ |
| 23 | 执行触发器任务 |
| 24 | @param trigger_task: 触发器任务数据 |
| 25 | @param kwargs: 额外数据 |
| 26 | @return: |
| 27 | """ |
| 28 | for simple_task_handler in simple_task_handlers: |
| 29 | if simple_task_handler.support(trigger_task, **kwargs): |
| 30 | Thread(target=simple_task_handler.execute, args=(trigger_task,), kwargs=kwargs).start() |
| 31 | return |
| 32 | raise Exception("不支持的处理器类型") |
| 33 | |
| 34 | |
| 35 | def deploy(trigger, **kwargs): |