googleapis/mcp-toolbox · error

error receiving from search lineage stream: %w

Error message

error receiving from search lineage stream: %w

What it means

Error "error receiving from search lineage stream: %w" thrown in googleapis/mcp-toolbox.

Source

Thrown at internal/sources/datalineage/datalineage.go:175

	if requestProcessDetails {
		ctx = metadata.AppendToOutgoingContext(ctx, "x-goog-fieldmask", "links,links.processes.process,unreachable")
	}

	stream, err := s.Client.SearchLineageStreaming(ctx, req)
	if err != nil {
		return nil, nil, fmt.Errorf("failed to start search lineage streaming: %w", err)
	}

	var links []*lineagepb.LineageLink
	unreachableMap := make(map[string]bool)
	for {
		resp, err := stream.Recv()
		if err == io.EOF {
			break
		}
		if err != nil {
			return nil, nil, fmt.Errorf("error receiving from search lineage stream: %w", err)
		}
		links = append(links, resp.GetLinks()...)
		for _, loc := range resp.GetUnreachable() {
			unreachableMap[loc] = true
		}
	}

	var unreachable []string
	if len(unreachableMap) > 0 {
		unreachable = make([]string, 0, len(unreachableMap))
		for loc := range unreachableMap {
			unreachable = append(unreachable, loc)
		}
	}

	return links, unreachable, nil
}

View on GitHub (pinned to 8cc6e09de2)

When it happens

Trigger: Thrown at internal/sources/datalineage/datalineage.go:175 when the library encounters an invalid state.

Common situations: See trigger scenarios.

AI-assisted analysis of googleapis/mcp-toolbox@8cc6e09de2 (2026-09-05). Data as JSON: /api/errors/5e12c580488c357e. Report an issue: GitHub.