| 4831 | } |
| 4832 | |
| 4833 | func (c *unixSocketClient) EnqueueTaskRun( |
| 4834 | ctx context.Context, |
| 4835 | id string, |
| 4836 | request EnqueueTaskRunRequest, |
| 4837 | ) (TaskRunRecord, error) { |
| 4838 | var response contract.TaskRunResponse |
| 4839 | path := "/api/tasks/" + url.PathEscape(strings.TrimSpace(id)) + "/runs" |
| 4840 | if err := c.doJSON(ctx, http.MethodPost, path, nil, request, &response); err != nil { |
| 4841 | return TaskRunRecord{}, err |
| 4842 | } |
| 4843 | return response.Run, nil |
| 4844 | } |
| 4845 | |
| 4846 | func (c *unixSocketClient) FanOutTaskRuns( |
| 4847 | ctx context.Context, |