Method loadBlueprintModule

core/schema/modulesource.go:792–831

(
	ctx context.Context,
	bk *engineutil.Client,
	src *core.ModuleSource,
)

}

func (s *moduleSourceSchema) loadBlueprintModule(
	ctx context.Context,
	bk *engineutil.Client,
	src *core.ModuleSource,
) error {
	dag, err := core.CurrentDagqlServer(ctx)
	if err != nil {
		return fmt.Errorf("failed to get dag server: %w", err)
	}

	jobs := parallel.New().WithContextualTracer(true).WithReveal(false)
	if src.ConfigBlueprint != nil {
		jobs = jobs.WithJob("load blueprint: "+src.ConfigBlueprint.Source, func(ctx context.Context) error {
			blueprint, err := core.ResolveDepToSource(ctx, bk, dag, src, src.ConfigBlueprint.Source, src.ConfigBlueprint.Pin, src.ConfigBlueprint.Name)
			if err != nil {
				return fmt.Errorf("failed to resolve blueprint to source: %w", err)
			}
			src.Blueprint = blueprint
			return nil
		})
	}
	if len(src.ConfigToolchains) > 0 {
		jobs = jobs.WithJob("load toolchains", func(ctx context.Context) error {
			src.Toolchains = make([]dagql.ObjectResult[*core.ModuleSource], len(src.ConfigToolchains))
			toolchainJobs := parallel.New().WithReveal(false).WithContextualTracer(true)
			for i, pcfg := range src.ConfigToolchains {
				toolchainJobs = toolchainJobs.WithJob(pcfg.Name, func(ctx context.Context) error {
					toolchain, err := core.ResolveDepToSource(ctx, bk, dag, src, pcfg.Source, pcfg.Pin, pcfg.Name)
					if err != nil {
						return fmt.Errorf("failed to resolve toolchain to source: %w", err)
					}
					src.Toolchains[i] = toolchain
					return nil
				})
			}
			return toolchainJobs.Run(ctx)
		})
	}
	return jobs.Run(ctx)
}

type directoryAsModuleArgs struct {
	SourceRootPath string `default:"."`