Method DynamicInputsForCall

core/modfunc.go:627–787

nolint:gocyclo // intrinsically long state machine; refactoring would hurt clarity

(
	ctx context.Context,
	parent dagql.AnyResult,
	args map[string]dagql.Input,
	view call.View,
	req *dagql.CallRequest,
)

//nolint:gocyclo // intrinsically long state machine; refactoring would hurt clarity
func (fn *ModuleFunction) DynamicInputsForCall(
	ctx context.Context,
	parent dagql.AnyResult,
	args map[string]dagql.Input,
	view call.View,
	req *dagql.CallRequest,
) error {
	var ctxArgs []*FunctionArg
	var workspaceArgs []*FunctionArg
	var userDefaults []*UserDefault

	// The decoded args map includes schema defaults, but the call ID only
	// contains arguments the caller explicitly provided. Use the call ID so
	// .env user defaults can still override schema defaults like Python "= None".
	explicitArgs := map[string]bool{}
	for _, idArg := range req.Args {
		explicitArgs[idArg.Name] = true
	}

	for _, argMetadataRes := range fn.metadata.Args {
		argMetadata := argMetadataRes.Self()
		if explicitArgs[argMetadata.Name] {
			// was explicitly set by the user, skip
			continue
		}
		if argMetadata.TypeDef.Self().Kind != TypeDefKindObject &&
			(argMetadata.TypeDef.Self().Kind != TypeDefKindList ||
				!argMetadata.TypeDef.Self().AsList.Valid ||
				argMetadata.TypeDef.Self().AsList.Value.Self() == nil ||
				argMetadata.TypeDef.Self().AsList.Value.Self().ElementTypeDef.Self() == nil ||
				argMetadata.TypeDef.Self().AsList.Value.Self().ElementTypeDef.Self().Kind != TypeDefKindObject) {
			// Only default objects need processing at this time.
			// Primitive default values were already processes earlier
			//  in the flow.
			// This applies to both types of object defaults:
			//  1) "contextual args" from `defaultPath` annotations
			//  2) "user defaults" from user-defined .env
			//  3) "workspace args" that are automatically injected
			continue
		}
		// Check for Workspace arguments first - they're always injected
		if argMetadata.IsWorkspace() {
			workspaceArgs = append(workspaceArgs, argMetadata)
			continue
		}
		userDefault, hasUserDefault, err := fn.UserDefault(ctx, argMetadata.Name)
		if err != nil {
			return fmt.Errorf("%s.%s(%s=): load user default: %w",
				fn.mod.Self().Name(),
				fn.metadata.Name,
				argMetadata.Name,
				err,
			)
		}
		if hasUserDefault {
			userDefaults = append(userDefaults, userDefault)
		} else if argMetadata.isContextual() {
			ctxArgs = append(ctxArgs, argMetadata)