code: func (c *Controller) Query(ctx context.Context, req *query.Request) (flux.Query, error) {
  	// Set the request on the context so platform specific Flux operations can retrieve it later.
  	ctx = query.ContextWithRequest(ctx, req)
  	// Set the org label value for controller metrics
  	ctx = context.WithValue(ctx, orgLabel, req.OrganizationID.String())
  	q, err := c.c.Query(ctx, req.Compiler)
  	if err != nil {
  		// If the controller reports an error, it's usually because of a syntax error
  		// or other problem that the client must fix.
  		return q, &platform.Error{
  			Code: platform.EInvalid,
  			Msg:  err.Error(),
  		}
  	}
  
  	return q, nil
  }
docs: // Query satisfies the AsyncQueryService while ensuring the request is propagated on the context.