impl

package

v0.0.10 Latest Latest Go to latest Published: Apr 10, 2026 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type TaskServiceImpl struct {
	ioc.ObjectImpl
	// contains filtered or unexported fields
}

func (i *TaskServiceImpl) CheckScheduleTimeout(ctx context.Context, timeoutSeconds int) error

CheckScheduleTimeout 检查并处理调度超时的任务对于Agent模式下运行超过指定秒数但未被调度的任务，标记为失败

func (i *TaskServiceImpl) DescribeTask(ctx context.Context, in *task.DescribeTaskRequest) (*task.Task, error)

DescribeAgent implements agent.Service.

func (i *TaskServiceImpl) Init() error

func (i *TaskServiceImpl) Name() string

func (s *TaskServiceImpl) QueryTask(ctx context.Context, in *task.QueryTaskRequest) (*types.Set[*task.Task], error)

QueryAgent implements agent.Service.

func (i *TaskServiceImpl) ReRunTask(ctx context.Context, in *task.ReRunTaskRequest) (*task.Task, error)

ReRunTask 重新运行任务 Clone=false: 重新运行原任务（重置状态后再次执行） Clone=true: 克隆为新任务运行（保留原任务记录，仅限独立任务）

func (i *TaskServiceImpl) RunTask(ctx context.Context, in *task.Task) error

RunTask implements task.Service.

func (i *TaskServiceImpl) SaveTask(ctx context.Context, in *task.Task) error

func (i *TaskServiceImpl) UpdateScheduleConfirmed(ctx context.Context, taskId string, confirmed bool) error

UpdateScheduleConfirmed 更新任务的调度确认状态只更新 scheduled_confirmed 字段，避免覆盖任务的其他字段

func (i *TaskServiceImpl) UpdateTaskStatus(ctx context.Context, in *task.Task) error

任务状态更新