AI features based on 3rd-party integrations
Introduced in GitLab 15.11.
Features
- Async execution of the long running API requests
- GraphQL Action starts the request
- Background workers execute
- GraphQL subscriptions deliver results back in real time
- Abstraction for
- Google Vertex AI
- Anthropic
- Rate Limiting
- Circuit Breaker
- Multi-Level feature flags
- License checks on group level
- Snowplow execution tracking
- Tracking of Token Spent on Prometheus
- Configuration for Moderation check of inputs
- Automatic Markdown Rendering of responses
- Centralised Group Level settings for experiment and 3rd party
- Experimental API endpoints for exploration of AI APIs by GitLab team members without the need for credentials
- Google Vertex AI
- Anthropic
Feature flags
Apply the following two feature flags to any AI feature work:
- A general flag (
ai_global_switch
) that applies to all AI features. - A flag specific to that feature. The feature flag name must be different than the licensed feature name.
See the feature flag tracker epic for the list of all feature flags and how to use them.
Implement a new AI action
To implement a new AI action, connect to the preferred AI provider. You can connect to this API using either the:
- Experimental REST API.
- Abstraction layer.
All AI features are experimental.
Test SaaS-only AI features locally
One-line setup
# Replace the <test-group-name> by the group name you want to enable GitLab Duo features. If the group doesn't exist, it creates a new one.
RAILS_ENV=development bundle exec rake gitlab:duo:setup['<test-group-name>']
Manual way
-
Enable the required general feature flags:
Feature.enable(:ai_global_switch, type: :ops)
-
Ensure you have followed the process to obtain an EE license for your local instance
-
Simulate the GDK to simulate SaaS and ensure the group you want to test has an Ultimate license
-
Enable
Experiment & Beta features
- Go to the group with the Ultimate license
- Group Settings > General -> Permissions and group features
- Enable Experiment & Beta features
-
Enable the specific feature flag for the feature you want to test
-
You can use Rake task
rake gitlab:duo:enable_feature_flags
to enable all feature flags that are assigned to group AI Framework -
Set the required access token. To receive an access token:
- For Vertex, follow the instructions below.
- For Anthropic, create an access request
Set up the embedding database
For features that use the embedding database, additional setup is needed.
-
Enable
pgvector
in GDK -
Enable the embedding database in GDK
gdk config set gitlab.rails.databases.embedding.enabled true
-
Run
gdk reconfigure
-
Run database migrations to create the embedding database
Configure GCP Vertex access
In order to obtain a GCP service key for local development, follow the steps below:
- Create a sandbox GCP project by visiting this page and following the instructions, or by requesting access to our existing group GCP project by using this template.
- If you are using an individual GCP project, you may also need to enable the Vertex AI API:
- Visit welcome page, choose your project (e.g. jdoe-5d23dpe).
- Go to APIs & Services > Enabled APIs & services.
- Select + Enable APIs and Services.
- Search for
Vertex AI API
. - Select Vertex AI API, then select Enable.
- Install the
gcloud
CLI - Authenticate locally with GCP using the
gcloud auth application-default login
command. - Open the Rails console. Update the settings to:
# PROJECT_ID = "your-gcp-project-name"
Gitlab::CurrentSettings.update(vertex_ai_project: PROJECT_ID)
Configure Anthropic access
Gitlab::CurrentSettings.update!(anthropic_api_key: <insert API key>)
Populating embeddings and using embeddings fixture
Embeddings are generated through VertexAI text embeddings endpoint. The sections below explain how to populate embeddings in the DB or extract embeddings to be used in specs.
VertexAI embeddings
To seed your development database with the embeddings for GitLab Documentation, you may use the pre-generated embeddings and a Rake task.
RAILS_ENV=development bundle exec rake gitlab:llm:embeddings:vertex:seed
The DBCleaner gem we use clear the database tables before each test runs.
Instead of fully populating the table vertex_gitlab_docs
where we store VertexAI embeddings for the documentations,
we can add a few selected embeddings to the table from a pre-generated fixture.
For instance, to test that the question "How can I reset my password" is correctly retrieving the relevant embeddings and answered, we can extract the top N closet embeddings to the question into a fixture and only restore a small number of embeddings quickly. To facilitate an extraction process, a Rake task has been written. You can add or remove the questions needed to be tested in the Rake task and run the task to generate a new fixture.
RAILS_ENV=development bundle exec rake gitlab:llm:embeddings:vertex:extract_embeddings
Using embeddings in specs
In the specs where you need to use the embeddings,
use the RSpec config hook :ai_embedding_fixtures
on a context.
context 'when asking about how to use GitLab', :ai_embedding_fixtures do
# ...examples
end
Tips for local development
- When responses are taking too long to appear in the user interface, consider restarting Sidekiq by running
gdk restart rails-background-jobs
. If that doesn't work, trygdk kill
and thengdk start
. - Alternatively, bypass Sidekiq entirely and run the chat service synchronously. This can help with debugging errors as GraphQL errors are now available in the network inspector instead of the Sidekiq logs. To do that temporary alter
Llm::CompletionWorker.perform_async
statements withLlm::CompletionWorker.perform_inline
Working with GitLab Duo Chat
View guidelines for working with GitLab Duo Chat.
Test AI features with AI Gateway locally
Introduced in GitLab 16.8.
In order to develop an AI feature that is compatible with both SaaS and Self-managed GitLab instances, the feature must request to the AI Gateway instead of directly requesting to the 3rd party model providers. Therefore, a different setup is required from the SaaS-only AI features.
Setup
- Set up AI Gateway:
-
Ensure that the following environment variables are set in the
.env
file:AIGW_AUTH__BYPASS_EXTERNAL=true ANTHROPIC_API_KEY="[REDACTED]" # IMPORTANT: Ensure you use Corp account. See https://gitlab.com/gitlab-org/gitlab/-/issues/435911#note_1701762954. AIGW_VERTEX_TEXT_MODEL__PROJECT="[REDACTED]"
-
Run
poetry run ai_gateway
. -
Visit OpenAPI playground (
http://0.0.0.0:5052/docs
), try an endpoint (e.g./v1/chat/agent
) and make sure you get a successful response. If something went wrong, checkmodelgateway_debug.log
if it contains error information.
- Setup GitLab Development Kit (GDK):
-
Activate GitLab Enterprise license (e.g. Ultimate).
-
Export these environment variables in the same terminal session with
gdk start
:export CODE_SUGGESTIONS_BASE_URL=http://0.0.0.0:5052 # URL to the local AI Gateway instance export LLM_DEBUG=1 # Enable debug logging
Alternatively, you can create an
env.runit
file in the root of your GDK with the above snippet. -
Enable the following feature flags via
gdk rails console
:# NOTE: This feature flag name might be changed. See https://gitlab.com/gitlab-org/gitlab/-/merge_requests/140352. ::Feature.enable(:ai_global_switch) # This is to request to AI Gateway instead of built-in Anthropic client. See https://gitlab.com/gitlab-org/gitlab/-/issues/433213 for more info. ::Feature.enable(:gitlab_duo_chat_requests_to_ai_gateway)
-
Create a dummy access token via
gdk rails console
OR skip this step and setup GitLab or Customer Dot as OIDC provider (See the following section):# Creating dummy token, and this will work as long as `AIGW_AUTH__BYPASS_EXTERNAL=true` in AI Gateway. ::Ai::ServiceAccessToken.create!(token: 'dummy', expires_at: 1.month.from_now)
-
Ensure GitLab-Rails can talk to the AI Gateway. Run
gdk rails console
and execute:user = User.first Gitlab::Llm::AiGateway::Client.new(user).stream(prompt: "\n\nHuman: Hi, how are you?\n\nAssistant:")
Verify the setup with GraphQL
-
Visit GraphQL explorer.
-
Execute the
aiAction
mutation. Here is an example:mutation { aiAction( input: { chat: { resourceId: "gid://gitlab/User/1", content: "Hello" } } ){ requestId errors } }
-
(GitLab Duo Chat only) Execute the following query to fetch the response:
query { aiMessages { nodes { requestId content role timestamp chunkId errors } } }
If you can't fetch the response, check
graphql_json.log
,sidekiq_json.log
,llm.log
ormodelgateway_debug.log
if it contains error information.
Use GitLab as OIDC provider in AI Gateway
- Reconfigure AI Gateway:
-
Additionally, ensure that the following environment variables are set in the
.env
file:AIGW_GITLAB_URL="http://gdk.test:3000/" AIGW_GITLAB_API_URL="http://gdk.test:3000/api/v4/" AIGW_AUTH__BYPASS_EXTERNAL=False
-
Restart AI Gateway.
-
- Reconfigure GitLab Development Kit (GDK):
-
Additionally, export the following environment variables:
export GITLAB_SIMULATE_SAAS=1 # Simulate a SaaS instance. See https://docs.gitlab.com/ee/development/ee_features.html#simulate-a-saas-instance.
-
Restart GDK.
-
Use Customer Dot as OIDC provider in AI Gateway
- AI Gateway:
- Ensure
AIGW_CUSTOMER_PORTAL_BASE_URL
in the.env
file points to your Customer Dot URL. - Restart
- Ensure
Experimental REST API
Use the experimental REST API endpoints to quickly experiment and prototype AI features.
The endpoints are:
https://gitlab.example.com/api/v4/ai/experimentation/anthropic/complete
https://gitlab.example.com/api/v4/ai/experimentation/vertex/chat
These endpoints are only for prototyping, not for rolling features out to customers.
In your local development environment, you can experiment with these endpoints locally with the feature flag enabled:
Feature.enable(:ai_experimentation_api)
On production, the experimental endpoints are only available to GitLab team members. Use a GitLab API token to authenticate.
Abstraction layer
GraphQL API
To connect to the AI provider API using the Abstraction Layer, use an extendable GraphQL API called
aiAction
.
The input
accepts key/value pairs, where the key
is the action that needs to be performed.
We only allow one AI action per mutation request.
Example of a mutation:
mutation {
aiAction(input: {summarizeComments: {resourceId: "gid://gitlab/Issue/52"}}) {
clientMutationId
}
}
As an example, assume we want to build an "explain code" action. To do this, we extend the input
with a new key,
explainCode
. The mutation would look like this:
mutation {
aiAction(input: {explainCode: {resourceId: "gid://gitlab/MergeRequest/52", code: "foo() { console.log() }" }}) {
clientMutationId
}
}
The GraphQL API then uses the Anthropic Client to send the response.
How to receive a response
The API requests to AI providers are handled in a background job. We therefore do not keep the request alive and the Frontend needs to match the request to the response from the subscription.
WARNING:
Determining the right response to a request can cause problems when only userId
and resourceId
are used. For example, when two AI features use the same userId
and resourceId
both subscriptions will receive the response from each other. To prevent this intereference, we introduced the clientSubscriptionId
.
To match a response on the aiCompletionResponse
subscription, you can provide a clientSubscriptionId
to the aiAction
mutation.
- The
clientSubscriptionId
should be unique per feature and within a page to not interfere with other AI features. We recommend to use aUUID
. - Only when the
clientSubscriptionId
is provided as part of theaiAction
mutation, it will be used for broadcasting theaiCompletionResponse
. - If the
clientSubscriptionId
is not provided, onlyuserId
andresourceId
are used for theaiCompletionResponse
.
As an example mutation for summarizing comments, we provide a randomId
as part of the mutation:
mutation {
aiAction(input: {summarizeComments: {resourceId: "gid://gitlab/Issue/52"}, clientSubscriptionId: "randomId"}) {
clientMutationId
}
}
In our component, we then listen on the aiCompletionResponse
using the userId
, resourceId
and clientSubscriptionId
("randomId"
):
subscription aiCompletionResponse($userId: UserID, $resourceId: AiModelID, $clientSubscriptionId: String) {
aiCompletionResponse(userId: $userId, resourceId: $resourceId, clientSubscriptionId: $clientSubscriptionId) {
content
errors
}
}
Note that the subscription for chat behaves differently.
To not have many concurrent subscriptions, you should also only subscribe to the subscription once the mutation is sent by using skip()
.
Current abstraction layer flow
The following graph uses VertexAI as an example. You can use different providers.
flowchart TD
A[GitLab frontend] -->B[AiAction GraphQL mutation]
B --> C[Llm::ExecuteMethodService]
C --> D[One of services, for example: Llm::GenerateSummaryService]
D -->|scheduled| E[AI worker:Llm::CompletionWorker]
E -->F[::Gitlab::Llm::Completions::Factory]
F -->G[`::Gitlab::Llm::VertexAi::Completions::...` class using `::Gitlab::Llm::Templates::...` class]
G -->|calling| H[Gitlab::Llm::VertexAi::Client]
H --> |response| I[::Gitlab::Llm::GraphqlSubscriptionResponseService]
I --> J[GraphqlTriggers.ai_completion_response]
J --> K[::GitlabSchema.subscriptions.trigger]
How to implement a new action
Register a new method
Go to the Llm::ExecuteMethodService
and add a new method with the new service class you will create.
class ExecuteMethodService < BaseService
METHODS = {
# ...
amazing_new_ai_feature: Llm::AmazingNewAiFeatureService
}.freeze
Create a Service
- Create a new service under
ee/app/services/llm/
and inherit it from theBaseService
. - The
resource
is the object we want to act on. It can be any object that includes theAi::Model
concern. For example it could be aProject
,MergeRequest
, orIssue
.
# ee/app/services/llm/amazing_new_ai_feature_service.rb
module Llm
class AmazingNewAiFeatureService < BaseService
private
def perform
::Llm::CompletionWorker.perform_async(user.id, resource.id, resource.class.name, :amazing_new_ai_feature)
success
end
def valid?
super && Ability.allowed?(user, :amazing_new_ai_feature, resource)
end
end
end
Authorization
We recommend to use policies to deal with authorization for a feature. Currently we need to make sure to cover the following checks:
- General AI feature flag (
ai_global_switch
) is enabled - Feature specific feature flag is enabled
- The namespace has the required license for the feature
- User is a member of the group/project
-
experiment_features_enabled
settings are set on theNamespace
For our example, we need to implement the allowed?(:amazing_new_ai_feature)
call. As an example, you can look at the Issue Policy for the summarize comments feature. In our example case, we want to implement the feature for Issues as well:
# ee/app/policies/ee/issue_policy.rb
module EE
module IssuePolicy
extend ActiveSupport::Concern
prepended do
with_scope :subject
condition(:ai_available) do
::Feature.enabled?(:ai_global_switch, type: :ops)
end
with_scope :subject
condition(:amazing_new_ai_feature_enabled) do
::Feature.enabled?(:amazing_new_ai_feature, subject_container) &&
subject_container.licensed_feature_available?(:amazing_new_ai_feature)
end
rule do
ai_available & amazing_new_ai_feature_enabled & is_project_member
end.enable :amazing_new_ai_feature
end
end
end
Pairing requests with responses
Because multiple users' requests can be processed in parallel, when receiving responses,
it can be difficult to pair a response with its original request. The requestId
field can be used for this purpose, because both the request and response are assured
to have the same requestId
UUID.
Caching
AI requests and responses can be cached. Cached conversation is being used to display user interaction with AI features. In the current implementation, this cache is not used to skip consecutive calls to the AI service when a user repeats their requests.
query {
aiMessages {
nodes {
id
requestId
content
role
errors
timestamp
}
}
}
This cache is especially useful for chat functionality. For other services,
caching is disabled. (It can be enabled for a service by using cache_response: true
option.)
Caching has following limitations:
- Messages are stored in Redis stream.
- There is a single stream of messages per user. This means that all services currently share the same cache. If needed, this could be extended to multiple streams per user (after checking with the infrastructure team that Redis can handle the estimated amount of messages).
- Only the last 50 messages (requests + responses) are kept.
- Expiration time of the stream is 3 days since adding last message.
- User can access only their own messages. There is no authorization on the caching level, and any authorization (if accessed by not current user) is expected on the service layer.
Check if feature is allowed for this resource based on namespace settings
There is one setting allowed on root namespace level that restrict the use of AI features:
experiment_features_enabled
To check if that feature is allowed for a given namespace, call:
Gitlab::Llm::StageCheck.available?(namespace, :name_of_the_feature)
Add the name of the feature to the Gitlab::Llm::StageCheck
class. There are
arrays there that differentiate between experimental and beta features.
This way we are ready for the following different cases:
- If the feature is not in any array, the check will return
true
. For example, the feature was moved to GA.
To move the feature from the experimental phase to the beta phase, move the name of the feature from the EXPERIMENTAL_FEATURES
array to the BETA_FEATURES
array.
Implement calls to AI APIs and the prompts
The CompletionWorker
will call the Completions::Factory
which will initialize the Service and execute the actual call to the API.
In our example, we will use VertexAI and implement two new classes:
# /ee/lib/gitlab/llm/vertex_ai/completions/amazing_new_ai_feature.rb
module Gitlab
module Llm
module VertexAi
module Completions
class AmazingNewAiFeature < Gitlab::Llm::Completions::Base
def execute
prompt = ai_prompt_class.new(options[:user_input]).to_prompt
response = Gitlab::Llm::VertexAi::Client.new(user).text(content: prompt)
response_modifier = ::Gitlab::Llm::VertexAi::ResponseModifiers::Predictions.new(response)
::Gitlab::Llm::GraphqlSubscriptionResponseService.new(
user, nil, response_modifier, options: response_options
).execute
end
end
end
end
end
end
# /ee/lib/gitlab/llm/vertex_ai/templates/amazing_new_ai_feature.rb
module Gitlab
module Llm
module VertexAi
module Templates
class AmazingNewAiFeature
def initialize(user_input)
@user_input = user_input
end
def to_prompt
<<~PROMPT
You are an assistant that writes code for the following context:
context: #{user_input}
PROMPT
end
end
end
end
end
end
Because we support multiple AI providers, you may also use those providers for the same example:
Gitlab::Llm::VertexAi::Client.new(user)
Gitlab::Llm::Anthropic::Client.new(user)
Monitoring Ai Actions
- Error ratio and response latency apdex for each Ai action can be found on Sidekiq Service dashboard under SLI Detail:
llm_completion
. - Spent tokens, usage of each Ai feature and other statistics can be found on periscope dashboard.
Add Ai Action to GraphQL
TODO
Security
Refer to the secure coding guidelines for Artificial Intelligence (AI) features.