Method Call

core/modfunc.go:816–943

(ctx context.Context, opts *CallOpts)

}

func (fn *ModuleFunction) Call(ctx context.Context, opts *CallOpts) (t dagql.AnyResult, rerr error) {
	mod := fn.mod.Self()

	lg := bklog.G(ctx).WithField("module", mod.Name()).WithField("function", fn.metadata.Name)
	if fn.objDef != nil {
		lg = lg.WithField("object", fn.objDef.Name)
	}
	ctx = bklog.WithLogger(ctx, lg)

	// Capture analytics for the function call.
	// Calls without function name are internal and excluded.
	fn.recordCall(ctx)

	curCall := dagql.CurrentCall(ctx)
	execMD := engineutil.ExecutionMetadata{
		Internal: true,
	}
	if curCall != nil {
		callDigest, err := curCall.RecipeDigest(ctx)
		if err != nil {
			return nil, fmt.Errorf("compute function exec call digest: %w", err)
		}
		execMD.CallDigest = callDigest
	}

	callInputs, err := fn.setCallInputs(ctx, opts)
	if err != nil {
		return nil, fmt.Errorf("set call inputs: %w", err)
	}

	bklog.G(ctx).Debug("function call")
	defer func() {
		bklog.G(ctx).Debug("function call done")
		if rerr != nil {
			bklog.G(ctx).WithError(rerr).Error("function call errored")
		}
	}()

	parentJSON, err := json.Marshal(opts.ParentFields)
	if err != nil {
		return nil, fmt.Errorf("marshal parent value: %w", err)
	}

	fnCall := newFunctionCall(FunctionCall{
		Name:      fn.metadata.OriginalName,
		Parent:    parentJSON,
		InputArgs: callInputs,
	})
	if fn.objDef != nil {
		fnCall.ParentName = fn.objDef.OriginalName
	}

	var envContext dagql.ObjectResult[*Env]
	if env, ok, err := EnvFromContext(ctx); err != nil {
		return nil, fmt.Errorf("resolve function env context: %w", err)
	} else if ok {
		envContext = env
	}