Function enqueueFanOutTaskRuns

internal/api/core/tasks.go:1471–1495

(
	ctx context.Context,
	manager TaskService,
	actor taskpkg.ActorContext,
	taskID string,
	groupID string,
	req contract.FanOutTaskRunsRequest,
	prepared []preparedFanOutDesignation,
)

}

func enqueueFanOutTaskRuns(
	ctx context.Context,
	manager TaskService,
	actor taskpkg.ActorContext,
	taskID string,
	groupID string,
	req contract.FanOutTaskRunsRequest,
	prepared []preparedFanOutDesignation,
) ([]taskpkg.Run, error) {
	runs := make([]taskpkg.Run, 0, len(req.Designations))
	for index := range req.Designations {
		run, err := manager.EnqueueRun(ctx, taskpkg.EnqueueRun{
			TaskID:             taskID,
			IdempotencyKey:     prepared[index].idempotencyKey,
			NetworkChannel:     strings.TrimSpace(req.NetworkChannel),
			DesignationGroupID: groupID,
			Metadata:           prepared[index].metadata,
		}, actor)
		if err != nil {
			return nil, err
		}
		runs = append(runs, *run)
	}
	return runs, nil
}

// ClaimTaskRun claims one queued run.
func (h *BaseHandlers) ClaimTaskRun(c *gin.Context) {