Function resultCallRefFromIDInput

dagql/call_request_input.go:62–104

(ctx context.Context, id *call.ID)

}

func resultCallRefFromIDInput(ctx context.Context, id *call.ID) (*ResultCallRef, error) {
	if id == nil {
		return nil, fmt.Errorf("nil ID input")
	}
	if !id.IsHandle() {
		frame, err := resultCallFromRecipeIDInput(ctx, id)
		if err != nil {
			return nil, err
		}
		if frame == nil {
			return nil, nil
		}
		return &ResultCallRef{Call: frame}, nil
	}
	clientMetadata, err := engine.ClientMetadataFromContext(ctx)
	if err != nil {
		return nil, fmt.Errorf("resolve ID input %q: current client metadata: %w", idInputDebugString(id), err)
	}
	if clientMetadata.SessionID == "" {
		return nil, fmt.Errorf("resolve ID input %q: empty session ID", idInputDebugString(id))
	}
	cache, err := EngineCache(ctx)
	if err != nil {
		return nil, fmt.Errorf("resolve ID input %q: current dagql cache: %w", idInputDebugString(id), err)
	}
	shared, _, _, err := cache.sharedResultByResultID(
		ctx,
		clientMetadata.SessionID,
		sharedResultID(id.EngineResultID()),
		sharedResultLookupCanonicalEquivalent,
	)
	if err != nil {
		return nil, fmt.Errorf("resolve ID input %q: %w", idInputDebugString(id), err)
	}
	frame := shared.loadResultCall()
	if frame == nil {
		return nil, fmt.Errorf("resolve ID input %q: missing result call frame", idInputDebugString(id))
	}
	if frame.Type != nil && frame.Type.NamedType == "Query" {
		return nil, nil
	}
	return &ResultCallRef{ResultID: uint64(shared.id), shared: shared}, nil
}

func resultCallFromRecipeIDInput(ctx context.Context, id *call.ID) (*ResultCall, error) {
	if id == nil {