Method execMeta

core/container_exec.go:222–313

(
	ctx context.Context,
	opts ContainerExecOpts,
	parent *engineutil.ExecutionMetadata,
	moduleContext dagql.ObjectResult[*Module],
)

}

func (container *Container) execMeta(
	ctx context.Context,
	opts ContainerExecOpts,
	parent *engineutil.ExecutionMetadata,
	moduleContext dagql.ObjectResult[*Module],
) (*engineutil.ExecutionMetadata, error) {
	execMD := engineutil.ExecutionMetadata{}
	if parent != nil {
		execMD = *parent
	}

	query, err := CurrentQuery(ctx)
	if err != nil {
		return nil, err
	}
	clientMetadata, err := engine.ClientMetadataFromContext(ctx)
	if err != nil {
		return nil, err
	}
	if execMD.CallDigest == "" {
		if curCall := dagql.CurrentCall(ctx); curCall != nil {
			callDigest, err := curCall.RecipeDigest(ctx)
			if err != nil {
				return nil, fmt.Errorf("compute exec call digest: %w", err)
			}
			execMD.CallDigest = callDigest
		}
	}
	if execMD.HostAliases == nil {
		execMD.HostAliases = make(map[string][]string)
	}
	execMD.RedirectStdinPath = opts.RedirectStdin
	execMD.RedirectStdoutPath = opts.RedirectStdout
	execMD.RedirectStderrPath = opts.RedirectStderr
	execMD.SystemEnvNames = container.SystemEnvNames
	execMD.EnabledGPUs = container.EnabledGPUs
	if opts.NoInit {
		execMD.NoInit = true
	}

	var callerModDigest digest.Digest
	if moduleContext.Self() != nil {
		implementationScopedMod, err := ImplementationScopedModule(ctx, moduleContext)
		if err != nil {
			return nil, fmt.Errorf("failed to get implementation-scoped module from exec module context: %w", err)
		}
		callerModDigest, err = implementationScopedMod.ContentPreferredDigest(ctx)
		if err != nil {
			return nil, fmt.Errorf("failed to get implementation-scoped module digest from exec module context: %w", err)
		}
	} else if callerMod, err := query.CurrentModule(ctx); err == nil && callerMod.Self() != nil {
		implementationScopedMod, err := ImplementationScopedModule(ctx, callerMod)
		if err != nil {
			return nil, fmt.Errorf("failed to get caller implementation-scoped module: %w", err)
		}
		callerModDigest, err = implementationScopedMod.ContentPreferredDigest(ctx)
		if err != nil {
			return nil, fmt.Errorf("failed to get caller implementation-scoped module digest: %w", err)