googleapis/mcp-toolbox · error

failed to start search lineage streaming: %w

Error message

failed to start search lineage streaming: %w

What it means

Error "failed to start search lineage streaming: %w" thrown in googleapis/mcp-toolbox.

Source

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

		},
		Direction: direction,
	}

	if maxDepth > 0 || maxResults > 0 || maxProcessPerLink > 0 {
		req.Limits = &lineagepb.SearchLineageStreamingRequest_SearchLimits{
			MaxDepth:          maxDepth,
			MaxResults:        maxResults,
			MaxProcessPerLink: maxProcessPerLink,
		}
	}

	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
		}
	}

View on GitHub (pinned to 8cc6e09de2)

When it happens

Trigger: Thrown at internal/sources/datalineage/datalineage.go:164 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/c764f22145232974. Report an issue: GitHub.