| 162 | } |
| 163 | |
| 164 | func (h *HostAPIHandler) handleTasksCreate(ctx context.Context, raw json.RawMessage) (any, error) { |
| 165 | var params hostAPITaskCreateParams |
| 166 | if err := decodeHostAPIParams(raw, ¶ms); err != nil { |
| 167 | return nil, err |
| 168 | } |
| 169 | |
| 170 | manager, actor, err := h.taskManagerAndActor(ctx) |
| 171 | if err != nil { |
| 172 | return nil, err |
| 173 | } |
| 174 | spec, err := h.createTaskSpecFromRequest(ctx, params) |
| 175 | if err != nil { |
| 176 | return nil, err |
| 177 | } |
| 178 | |
| 179 | record, err := manager.CreateTask(ctx, spec, actor) |
| 180 | if err != nil { |
| 181 | return nil, mapTaskRPCError(spec.ID, err) |
| 182 | } |
| 183 | return taskPayloadFromTask(record), nil |
| 184 | } |
| 185 | |
| 186 | func (h *HostAPIHandler) handleTasksUpdate(ctx context.Context, raw json.RawMessage) (any, error) { |
| 187 | var params hostAPITaskUpdateParams |