Function prepareFanOutTaskRunsRequest

internal/api/core/tasks.go:1437–1469

(
	req contract.FanOutTaskRunsRequest,
	maxDesignations int,
)

}

func prepareFanOutTaskRunsRequest(
	req contract.FanOutTaskRunsRequest,
	maxDesignations int,
) ([]preparedFanOutDesignation, error) {
	if len(req.Designations) == 0 {
		return nil, NewTaskValidationError(errors.New("designations are required"))
	}
	if len(req.Designations) > maxDesignations {
		return nil, NewTaskValidationError(fmt.Errorf("designations cannot exceed %d", maxDesignations))
	}
	if err := validateTaskChannel("fan_out_runs.network_channel", req.NetworkChannel); err != nil {
		return nil, err
	}
	prepared := make([]preparedFanOutDesignation, 0, len(req.Designations))
	for index, designation := range req.Designations {
		metadata, err := fanOutDesignationMetadata(index, designation)
		if err != nil {
			return nil, err
		}
		idempotencyKey := fanOutDesignationIdempotencyKey(req.IdempotencyKey, designation, index)
		if idempotencyKey == "" {
			return nil, NewTaskValidationError(fmt.Errorf(
				"designations[%d].idempotency_key is required when fan_out_runs.idempotency_key is empty",
				index,
			))
		}
		prepared = append(prepared, preparedFanOutDesignation{
			idempotencyKey: idempotencyKey,
			metadata:       metadata,
		})
	}
	return prepared, nil
}

func enqueueFanOutTaskRuns(
	ctx context.Context,