googleapis/mcp-toolbox · error

failed to list sessions: %w

Error message

failed to list sessions: %w

What it means

The paginated Dataproc ListSessions RPC (pager.NextPage) failed — invalid page token/filter, missing permissions, or a transient API error while enumerating sessions.

Source

Thrown at internal/sources/serverlessspark/serverlessspark.go:413

	}

	if ps != nil {
		req.PageSize = int32(*ps)
	}
	if pt != "" {
		req.PageToken = pt
	}
	if filter != "" {
		req.Filter = filter
	}

	it := client.ListSessions(ctx, req)
	pager := iterator.NewPager(it, int(req.PageSize), req.PageToken)

	var sessionPbs []*dataprocpb.Session
	nextPageToken, err := pager.NextPage(&sessionPbs)
	if err != nil {
		return nil, fmt.Errorf("failed to list sessions: %w", err)
	}

	sessions, err := ToSessions(sessionPbs)
	if err != nil {
		return nil, err
	}

	return ListSessionsResponse{Sessions: sessions, NextPageToken: nextPageToken}, nil
}

func (s *Source) GetSession(ctx context.Context, name string) (map[string]any, error) {
	client := s.GetSessionControllerClient()
	req := &dataprocpb.GetSessionRequest{
		Name: fmt.Sprintf("projects/%s/locations/%s/sessions/%s", s.GetProject(), s.GetLocation(), name),
	}

	sessionPb, err := client.GetSession(ctx, req)
	if err != nil {

View on GitHub (pinned to 8cc6e09de2)

Solutions

  1. Verify pageSize/pageToken/filter values
  2. Check IAM list permissions on the project/location
  3. Retry on transient Google API errors
Defensive patterns

Strategy: retry

When it happens

Trigger: Thrown at internal/sources/serverlessspark/serverlessspark.go:413 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/a28c5d6c536fb5e4. Report an issue: GitHub.