INNER CODE UNIT · Go

authFunc

datastax-archive/kaskada · wren/main.go:195

	authFunc := auth.ClientIDHeaderAuthFunc(*defaultClientID, ownerClient)

	// populate parallize config
	// see: https://github.com/kaskada-ai/kaskada/issues/69
	var parallelizeConfig *utils.ParallelizeConfig
	if entConfig.DriverName() == "sqlite3" {
		if *prepareParallelizeFactor > 1 || *queryParallelizeFactor > 1 {
			log.Warn().Msg("sqlite backing store currently doesn't support parallel operation.  setting all parallization factors to 1.")
		}
		parallelizeConfig = &utils.ParallelizeConfig{
			PrepareFactor: 1,
			QueryFactor:   1,
		}
	} else {
		parallelizeConfig = &utils.ParallelizeConfig{
			PrepareFactor: *prepareParallelizeFactor,
			QueryFactor:   *queryParallelizeFactor,
		}

View source record →