diff --git a/Protos/connector_service.proto b/Protos/connector_service.proto
index d73af18..195b7fc 100644
--- a/Protos/connector_service.proto
+++ b/Protos/connector_service.proto
@@ -1,4 +1,4 @@
-// Copyright 2024 Google LLC
+// Copyright 2025 Google LLC
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -16,42 +16,24 @@
 //adopted from third_party/firebase/dataconnect/emulator/server/api/connector_service.proto
 syntax = "proto3";
 
-package google.firebase.dataconnect.v1beta;
+package google.firebase.dataconnect.v1;
 
 import "google/api/annotations.proto";
 import "google/api/field_behavior.proto";
 import "google/protobuf/struct.proto";
 import "graphql_error.proto";
 
-option java_package = "com.google.firebase.dataconnect.v1beta";
+option java_package = "com.google.firebase.dataconnect.v1";
 option java_multiple_files = true;
 option java_outer_classname = "ConnectorServiceProto";
 
 service ConnectorService {
   // Execute a predefined query in a Connector.
-  rpc ExecuteQuery(ExecuteQueryRequest) returns (ExecuteQueryResponse) {
-    option (google.api.http) = {
-      post: "/v1alpha/{name=projects/*/locations/*/services/*/connectors/*}:executeQuery"
-      body: "*"
-      additional_bindings {
-        post: "/v1beta/{name=projects/*/locations/*/services/*/connectors/*}:executeQuery"
-        body: "*"
-      }
-    };
-  }
+  rpc ExecuteQuery(ExecuteQueryRequest) returns (ExecuteQueryResponse) {}
 
   // Execute a predefined mutation in a Connector.
   rpc ExecuteMutation(ExecuteMutationRequest)
-      returns (ExecuteMutationResponse) {
-    option (google.api.http) = {
-      post: "/v1alpha/{name=projects/*/locations/*/services/*/connectors/*}:executeMutation"
-      body: "*"
-      additional_bindings {
-        post: "/v1beta/{name=projects/*/locations/*/services/*/connectors/*}:executeMutation"
-        body: "*"
-      }
-    };
-  }
+      returns (ExecuteMutationResponse) {}
 }
 
 // The ExecuteQuery request to Firebase Data Connect.
diff --git a/Protos/graphql_error.proto b/Protos/graphql_error.proto
index 87d8535..00c486a 100644
--- a/Protos/graphql_error.proto
+++ b/Protos/graphql_error.proto
@@ -1,4 +1,4 @@
-// Copyright 2024 Google LLC
+// Copyright 2025 Google LLC
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -16,11 +16,11 @@
 
 syntax = "proto3";
 
-package google.firebase.dataconnect.v1beta;
+package google.firebase.dataconnect.v1;
 
 import "google/protobuf/struct.proto";
 
-option java_package = "com.google.firebase.dataconnect.v1beta";
+option java_package = "com.google.firebase.dataconnect.v1";
 option java_multiple_files = true;
 option java_outer_classname = "GraphqlErrorProto";
 
diff --git a/Sources/Internal/Codec.swift b/Sources/Internal/Codec.swift
index 2f01bbe..6478f14 100644
--- a/Sources/Internal/Codec.swift
+++ b/Sources/Internal/Codec.swift
@@ -18,9 +18,9 @@ import SwiftProtobuf
 
 @available(iOS 15.0, macOS 12.0, tvOS 15.0, watchOS 8.0, *)
 typealias FirebaseDataConnectExecuteMutationRequest =
-  Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest
+  Google_Firebase_Dataconnect_V1_ExecuteMutationRequest
 typealias FirebaseDataConnectExecuteQueryRequest =
-  Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest
+  Google_Firebase_Dataconnect_V1_ExecuteQueryRequest
 
 @available(iOS 15.0, macOS 12.0, tvOS 15.0, watchOS 8.0, *)
 class Codec {
diff --git a/Sources/Internal/GrpcClient.swift b/Sources/Internal/GrpcClient.swift
index b9a3dbd..d98bda9 100644
--- a/Sources/Internal/GrpcClient.swift
+++ b/Sources/Internal/GrpcClient.swift
@@ -27,8 +27,8 @@ import SwiftProtobuf
 
 @available(iOS 15.0, macOS 12.0, tvOS 15.0, watchOS 8.0, *)
 typealias FirebaseDataConnectAsyncClient =
-  Google_Firebase_Dataconnect_V1beta_ConnectorServiceAsyncClient
-typealias FirebaseDataConnectGraphqlError = Google_Firebase_Dataconnect_V1beta_GraphqlError
+  Google_Firebase_Dataconnect_V1_ConnectorServiceAsyncClient
+typealias FirebaseDataConnectGraphqlError = Google_Firebase_Dataconnect_V1_GraphqlError
 
 @available(iOS 15.0, macOS 12.0, tvOS 15.0, watchOS 8.0, *)
 actor GrpcClient: CustomStringConvertible {
diff --git a/Sources/ProtoGen/connector_service.grpc.swift b/Sources/ProtoGen/connector_service.grpc.swift
index d466b10..7abc659 100644
--- a/Sources/ProtoGen/connector_service.grpc.swift
+++ b/Sources/ProtoGen/connector_service.grpc.swift
@@ -6,7 +6,7 @@
 // Source: connector_service.proto
 //
 
-// Copyright 2024 Google LLC
+// Copyright 2025 Google LLC
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -25,28 +25,28 @@ import NIO
 import NIOConcurrencyHelpers
 import SwiftProtobuf
 
-/// Usage: instantiate `Google_Firebase_Dataconnect_V1beta_ConnectorServiceClient`, then call
-/// methods of this protocol to make API calls.
-public protocol Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientProtocol: GRPCClient {
+/// Usage: instantiate `Google_Firebase_Dataconnect_V1_ConnectorServiceClient`, then call methods of
+/// this protocol to make API calls.
+public protocol Google_Firebase_Dataconnect_V1_ConnectorServiceClientProtocol: GRPCClient {
   var serviceName: String { get }
-  var interceptors: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientInterceptorFactoryProtocol? {
+  var interceptors: Google_Firebase_Dataconnect_V1_ConnectorServiceClientInterceptorFactoryProtocol? {
     get
   }
 
-  func executeQuery(_ request: Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest,
+  func executeQuery(_ request: Google_Firebase_Dataconnect_V1_ExecuteQueryRequest,
                     callOptions: CallOptions?)
-    -> UnaryCall<Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest,
-      Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse>
+    -> UnaryCall<Google_Firebase_Dataconnect_V1_ExecuteQueryRequest,
+      Google_Firebase_Dataconnect_V1_ExecuteQueryResponse>
 
-  func executeMutation(_ request: Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest,
+  func executeMutation(_ request: Google_Firebase_Dataconnect_V1_ExecuteMutationRequest,
                        callOptions: CallOptions?)
-    -> UnaryCall<Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest,
-      Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse>
+    -> UnaryCall<Google_Firebase_Dataconnect_V1_ExecuteMutationRequest,
+      Google_Firebase_Dataconnect_V1_ExecuteMutationResponse>
 }
 
-public extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientProtocol {
+public extension Google_Firebase_Dataconnect_V1_ConnectorServiceClientProtocol {
   var serviceName: String {
-    return "google.firebase.dataconnect.v1beta.ConnectorService"
+    return "google.firebase.dataconnect.v1.ConnectorService"
   }
 
   /// Execute a predefined query in a Connector.
@@ -55,13 +55,12 @@ public extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientProtoc
   ///   - request: Request to send to ExecuteQuery.
   ///   - callOptions: Call options.
   /// - Returns: A `UnaryCall` with futures for the metadata, status and response.
-  func executeQuery(_ request: Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest,
+  func executeQuery(_ request: Google_Firebase_Dataconnect_V1_ExecuteQueryRequest,
                     callOptions: CallOptions? = nil)
-    -> UnaryCall<Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest,
-      Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse> {
+    -> UnaryCall<Google_Firebase_Dataconnect_V1_ExecuteQueryRequest,
+      Google_Firebase_Dataconnect_V1_ExecuteQueryResponse> {
     return makeUnaryCall(
-      path: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientMetadata.Methods.executeQuery
-        .path,
+      path: Google_Firebase_Dataconnect_V1_ConnectorServiceClientMetadata.Methods.executeQuery.path,
       request: request,
       callOptions: callOptions ?? defaultCallOptions,
       interceptors: interceptors?.makeExecuteQueryInterceptors() ?? []
@@ -74,13 +73,13 @@ public extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientProtoc
   ///   - request: Request to send to ExecuteMutation.
   ///   - callOptions: Call options.
   /// - Returns: A `UnaryCall` with futures for the metadata, status and response.
-  func executeMutation(_ request: Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest,
+  func executeMutation(_ request: Google_Firebase_Dataconnect_V1_ExecuteMutationRequest,
                        callOptions: CallOptions? = nil)
-    -> UnaryCall<Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest,
-      Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse> {
+    -> UnaryCall<Google_Firebase_Dataconnect_V1_ExecuteMutationRequest,
+      Google_Firebase_Dataconnect_V1_ExecuteMutationResponse> {
     return makeUnaryCall(
-      path: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientMetadata.Methods
-        .executeMutation.path,
+      path: Google_Firebase_Dataconnect_V1_ConnectorServiceClientMetadata.Methods.executeMutation
+        .path,
       request: request,
       callOptions: callOptions ?? defaultCallOptions,
       interceptors: interceptors?.makeExecuteMutationInterceptors() ?? []
@@ -89,25 +88,25 @@ public extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientProtoc
 }
 
 @available(*, deprecated)
-extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceClient: @unchecked Sendable {}
+extension Google_Firebase_Dataconnect_V1_ConnectorServiceClient: @unchecked Sendable {}
 
-@available(*, deprecated, renamed: "Google_Firebase_Dataconnect_V1beta_ConnectorServiceNIOClient")
-public final class Google_Firebase_Dataconnect_V1beta_ConnectorServiceClient: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientProtocol {
+@available(*, deprecated, renamed: "Google_Firebase_Dataconnect_V1_ConnectorServiceNIOClient")
+public final class Google_Firebase_Dataconnect_V1_ConnectorServiceClient: Google_Firebase_Dataconnect_V1_ConnectorServiceClientProtocol {
   private let lock = Lock()
   private var _defaultCallOptions: CallOptions
-  private var _interceptors: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientInterceptorFactoryProtocol?
+  private var _interceptors: Google_Firebase_Dataconnect_V1_ConnectorServiceClientInterceptorFactoryProtocol?
   public let channel: GRPCChannel
   public var defaultCallOptions: CallOptions {
     get { lock.withLock { self._defaultCallOptions } }
     set { lock.withLockVoid { self._defaultCallOptions = newValue } }
   }
 
-  public var interceptors: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientInterceptorFactoryProtocol? {
+  public var interceptors: Google_Firebase_Dataconnect_V1_ConnectorServiceClientInterceptorFactoryProtocol? {
     get { lock.withLock { self._interceptors } }
     set { lock.withLockVoid { self._interceptors = newValue } }
   }
 
-  /// Creates a client for the google.firebase.dataconnect.v1beta.ConnectorService service.
+  /// Creates a client for the google.firebase.dataconnect.v1.ConnectorService service.
   ///
   /// - Parameters:
   ///   - channel: `GRPCChannel` to the service host.
@@ -115,7 +114,7 @@ public final class Google_Firebase_Dataconnect_V1beta_ConnectorServiceClient: Go
   ///   - interceptors: A factory providing interceptors for each RPC.
   public init(channel: GRPCChannel,
               defaultCallOptions: CallOptions = CallOptions(),
-              interceptors: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientInterceptorFactoryProtocol? =
+              interceptors: Google_Firebase_Dataconnect_V1_ConnectorServiceClientInterceptorFactoryProtocol? =
                 nil) {
     self.channel = channel
     _defaultCallOptions = defaultCallOptions
@@ -123,12 +122,12 @@ public final class Google_Firebase_Dataconnect_V1beta_ConnectorServiceClient: Go
   }
 }
 
-public struct Google_Firebase_Dataconnect_V1beta_ConnectorServiceNIOClient: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientProtocol {
+public struct Google_Firebase_Dataconnect_V1_ConnectorServiceNIOClient: Google_Firebase_Dataconnect_V1_ConnectorServiceClientProtocol {
   public var channel: GRPCChannel
   public var defaultCallOptions: CallOptions
-  public var interceptors: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientInterceptorFactoryProtocol?
+  public var interceptors: Google_Firebase_Dataconnect_V1_ConnectorServiceClientInterceptorFactoryProtocol?
 
-  /// Creates a client for the google.firebase.dataconnect.v1beta.ConnectorService service.
+  /// Creates a client for the google.firebase.dataconnect.v1.ConnectorService service.
   ///
   /// - Parameters:
   ///   - channel: `GRPCChannel` to the service host.
@@ -136,7 +135,7 @@ public struct Google_Firebase_Dataconnect_V1beta_ConnectorServiceNIOClient: Goog
   ///   - interceptors: A factory providing interceptors for each RPC.
   public init(channel: GRPCChannel,
               defaultCallOptions: CallOptions = CallOptions(),
-              interceptors: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientInterceptorFactoryProtocol? =
+              interceptors: Google_Firebase_Dataconnect_V1_ConnectorServiceClientInterceptorFactoryProtocol? =
                 nil) {
     self.channel = channel
     self.defaultCallOptions = defaultCallOptions
@@ -145,53 +144,52 @@ public struct Google_Firebase_Dataconnect_V1beta_ConnectorServiceNIOClient: Goog
 }
 
 @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
-public protocol Google_Firebase_Dataconnect_V1beta_ConnectorServiceAsyncClientProtocol: GRPCClient {
+public protocol Google_Firebase_Dataconnect_V1_ConnectorServiceAsyncClientProtocol: GRPCClient {
   static var serviceDescriptor: GRPCServiceDescriptor { get }
-  var interceptors: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientInterceptorFactoryProtocol? {
+  var interceptors: Google_Firebase_Dataconnect_V1_ConnectorServiceClientInterceptorFactoryProtocol? {
     get
   }
 
-  func makeExecuteQueryCall(_ request: Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest,
+  func makeExecuteQueryCall(_ request: Google_Firebase_Dataconnect_V1_ExecuteQueryRequest,
                             callOptions: CallOptions?)
-    -> GRPCAsyncUnaryCall<Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest,
-      Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse>
+    -> GRPCAsyncUnaryCall<Google_Firebase_Dataconnect_V1_ExecuteQueryRequest,
+      Google_Firebase_Dataconnect_V1_ExecuteQueryResponse>
 
-  func makeExecuteMutationCall(_ request: Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest,
+  func makeExecuteMutationCall(_ request: Google_Firebase_Dataconnect_V1_ExecuteMutationRequest,
                                callOptions: CallOptions?)
-    -> GRPCAsyncUnaryCall<Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest,
-      Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse>
+    -> GRPCAsyncUnaryCall<Google_Firebase_Dataconnect_V1_ExecuteMutationRequest,
+      Google_Firebase_Dataconnect_V1_ExecuteMutationResponse>
 }
 
 @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
-public extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceAsyncClientProtocol {
+public extension Google_Firebase_Dataconnect_V1_ConnectorServiceAsyncClientProtocol {
   static var serviceDescriptor: GRPCServiceDescriptor {
-    return Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientMetadata.serviceDescriptor
+    return Google_Firebase_Dataconnect_V1_ConnectorServiceClientMetadata.serviceDescriptor
   }
 
-  var interceptors: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientInterceptorFactoryProtocol? {
+  var interceptors: Google_Firebase_Dataconnect_V1_ConnectorServiceClientInterceptorFactoryProtocol? {
     return nil
   }
 
-  func makeExecuteQueryCall(_ request: Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest,
+  func makeExecuteQueryCall(_ request: Google_Firebase_Dataconnect_V1_ExecuteQueryRequest,
                             callOptions: CallOptions? = nil)
-    -> GRPCAsyncUnaryCall<Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest,
-      Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse> {
+    -> GRPCAsyncUnaryCall<Google_Firebase_Dataconnect_V1_ExecuteQueryRequest,
+      Google_Firebase_Dataconnect_V1_ExecuteQueryResponse> {
     return makeAsyncUnaryCall(
-      path: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientMetadata.Methods.executeQuery
-        .path,
+      path: Google_Firebase_Dataconnect_V1_ConnectorServiceClientMetadata.Methods.executeQuery.path,
       request: request,
       callOptions: callOptions ?? defaultCallOptions,
       interceptors: interceptors?.makeExecuteQueryInterceptors() ?? []
     )
   }
 
-  func makeExecuteMutationCall(_ request: Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest,
+  func makeExecuteMutationCall(_ request: Google_Firebase_Dataconnect_V1_ExecuteMutationRequest,
                                callOptions: CallOptions? = nil)
-    -> GRPCAsyncUnaryCall<Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest,
-      Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse> {
+    -> GRPCAsyncUnaryCall<Google_Firebase_Dataconnect_V1_ExecuteMutationRequest,
+      Google_Firebase_Dataconnect_V1_ExecuteMutationResponse> {
     return makeAsyncUnaryCall(
-      path: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientMetadata.Methods
-        .executeMutation.path,
+      path: Google_Firebase_Dataconnect_V1_ConnectorServiceClientMetadata.Methods.executeMutation
+        .path,
       request: request,
       callOptions: callOptions ?? defaultCallOptions,
       interceptors: interceptors?.makeExecuteMutationInterceptors() ?? []
@@ -200,25 +198,24 @@ public extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceAsyncClientP
 }
 
 @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
-public extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceAsyncClientProtocol {
-  func executeQuery(_ request: Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest,
+public extension Google_Firebase_Dataconnect_V1_ConnectorServiceAsyncClientProtocol {
+  func executeQuery(_ request: Google_Firebase_Dataconnect_V1_ExecuteQueryRequest,
                     callOptions: CallOptions? = nil) async throws
-    -> Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse {
+    -> Google_Firebase_Dataconnect_V1_ExecuteQueryResponse {
     return try await performAsyncUnaryCall(
-      path: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientMetadata.Methods.executeQuery
-        .path,
+      path: Google_Firebase_Dataconnect_V1_ConnectorServiceClientMetadata.Methods.executeQuery.path,
       request: request,
       callOptions: callOptions ?? defaultCallOptions,
       interceptors: interceptors?.makeExecuteQueryInterceptors() ?? []
     )
   }
 
-  func executeMutation(_ request: Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest,
+  func executeMutation(_ request: Google_Firebase_Dataconnect_V1_ExecuteMutationRequest,
                        callOptions: CallOptions? = nil) async throws
-    -> Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse {
+    -> Google_Firebase_Dataconnect_V1_ExecuteMutationResponse {
     return try await performAsyncUnaryCall(
-      path: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientMetadata.Methods
-        .executeMutation.path,
+      path: Google_Firebase_Dataconnect_V1_ConnectorServiceClientMetadata.Methods.executeMutation
+        .path,
       request: request,
       callOptions: callOptions ?? defaultCallOptions,
       interceptors: interceptors?.makeExecuteMutationInterceptors() ?? []
@@ -227,14 +224,14 @@ public extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceAsyncClientP
 }
 
 @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
-public struct Google_Firebase_Dataconnect_V1beta_ConnectorServiceAsyncClient: Google_Firebase_Dataconnect_V1beta_ConnectorServiceAsyncClientProtocol {
+public struct Google_Firebase_Dataconnect_V1_ConnectorServiceAsyncClient: Google_Firebase_Dataconnect_V1_ConnectorServiceAsyncClientProtocol {
   public var channel: GRPCChannel
   public var defaultCallOptions: CallOptions
-  public var interceptors: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientInterceptorFactoryProtocol?
+  public var interceptors: Google_Firebase_Dataconnect_V1_ConnectorServiceClientInterceptorFactoryProtocol?
 
   public init(channel: GRPCChannel,
               defaultCallOptions: CallOptions = CallOptions(),
-              interceptors: Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientInterceptorFactoryProtocol? =
+              interceptors: Google_Firebase_Dataconnect_V1_ConnectorServiceClientInterceptorFactoryProtocol? =
                 nil) {
     self.channel = channel
     self.defaultCallOptions = defaultCallOptions
@@ -242,65 +239,65 @@ public struct Google_Firebase_Dataconnect_V1beta_ConnectorServiceAsyncClient: Go
   }
 }
 
-public protocol Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientInterceptorFactoryProtocol: Sendable {
+public protocol Google_Firebase_Dataconnect_V1_ConnectorServiceClientInterceptorFactoryProtocol: Sendable {
   /// - Returns: Interceptors to use when invoking 'executeQuery'.
   func makeExecuteQueryInterceptors() -> [ClientInterceptor<
-    Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest,
-    Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse
+    Google_Firebase_Dataconnect_V1_ExecuteQueryRequest,
+    Google_Firebase_Dataconnect_V1_ExecuteQueryResponse
   >]
 
   /// - Returns: Interceptors to use when invoking 'executeMutation'.
   func makeExecuteMutationInterceptors() -> [ClientInterceptor<
-    Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest,
-    Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse
+    Google_Firebase_Dataconnect_V1_ExecuteMutationRequest,
+    Google_Firebase_Dataconnect_V1_ExecuteMutationResponse
   >]
 }
 
-public enum Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientMetadata {
+public enum Google_Firebase_Dataconnect_V1_ConnectorServiceClientMetadata {
   public static let serviceDescriptor = GRPCServiceDescriptor(
     name: "ConnectorService",
-    fullName: "google.firebase.dataconnect.v1beta.ConnectorService",
+    fullName: "google.firebase.dataconnect.v1.ConnectorService",
     methods: [
-      Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientMetadata.Methods.executeQuery,
-      Google_Firebase_Dataconnect_V1beta_ConnectorServiceClientMetadata.Methods.executeMutation,
+      Google_Firebase_Dataconnect_V1_ConnectorServiceClientMetadata.Methods.executeQuery,
+      Google_Firebase_Dataconnect_V1_ConnectorServiceClientMetadata.Methods.executeMutation,
     ]
   )
 
   public enum Methods {
     public static let executeQuery = GRPCMethodDescriptor(
       name: "ExecuteQuery",
-      path: "/google.firebase.dataconnect.v1beta.ConnectorService/ExecuteQuery",
+      path: "/google.firebase.dataconnect.v1.ConnectorService/ExecuteQuery",
       type: GRPCCallType.unary
     )
 
     public static let executeMutation = GRPCMethodDescriptor(
       name: "ExecuteMutation",
-      path: "/google.firebase.dataconnect.v1beta.ConnectorService/ExecuteMutation",
+      path: "/google.firebase.dataconnect.v1.ConnectorService/ExecuteMutation",
       type: GRPCCallType.unary
     )
   }
 }
 
 /// To build a server, implement a class that conforms to this protocol.
-public protocol Google_Firebase_Dataconnect_V1beta_ConnectorServiceProvider: CallHandlerProvider {
-  var interceptors: Google_Firebase_Dataconnect_V1beta_ConnectorServiceServerInterceptorFactoryProtocol? {
+public protocol Google_Firebase_Dataconnect_V1_ConnectorServiceProvider: CallHandlerProvider {
+  var interceptors: Google_Firebase_Dataconnect_V1_ConnectorServiceServerInterceptorFactoryProtocol? {
     get
   }
 
   /// Execute a predefined query in a Connector.
-  func executeQuery(request: Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest,
+  func executeQuery(request: Google_Firebase_Dataconnect_V1_ExecuteQueryRequest,
                     context: StatusOnlyCallContext)
-    -> EventLoopFuture<Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse>
+    -> EventLoopFuture<Google_Firebase_Dataconnect_V1_ExecuteQueryResponse>
 
   /// Execute a predefined mutation in a Connector.
-  func executeMutation(request: Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest,
+  func executeMutation(request: Google_Firebase_Dataconnect_V1_ExecuteMutationRequest,
                        context: StatusOnlyCallContext)
-    -> EventLoopFuture<Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse>
+    -> EventLoopFuture<Google_Firebase_Dataconnect_V1_ExecuteMutationResponse>
 }
 
-public extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceProvider {
+public extension Google_Firebase_Dataconnect_V1_ConnectorServiceProvider {
   var serviceName: Substring {
-    return Google_Firebase_Dataconnect_V1beta_ConnectorServiceServerMetadata.serviceDescriptor
+    return Google_Firebase_Dataconnect_V1_ConnectorServiceServerMetadata.serviceDescriptor
       .fullName[...]
   }
 
@@ -314,11 +311,10 @@ public extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceProvider {
       return UnaryServerHandler(
         context: context,
         requestDeserializer: ProtobufDeserializer<
-          Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest
-        >(),
-        responseSerializer: ProtobufSerializer<
-          Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse
+          Google_Firebase_Dataconnect_V1_ExecuteQueryRequest
         >(),
+        responseSerializer: ProtobufSerializer<Google_Firebase_Dataconnect_V1_ExecuteQueryResponse>(
+        ),
         interceptors: interceptors?.makeExecuteQueryInterceptors() ?? [],
         userFunction: executeQuery(request:context:)
       )
@@ -327,10 +323,10 @@ public extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceProvider {
       return UnaryServerHandler(
         context: context,
         requestDeserializer: ProtobufDeserializer<
-          Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest
+          Google_Firebase_Dataconnect_V1_ExecuteMutationRequest
         >(),
         responseSerializer: ProtobufSerializer<
-          Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse
+          Google_Firebase_Dataconnect_V1_ExecuteMutationResponse
         >(),
         interceptors: interceptors?.makeExecuteMutationInterceptors() ?? [],
         userFunction: executeMutation(request:context:)
@@ -344,36 +340,36 @@ public extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceProvider {
 
 /// To implement a server, implement an object which conforms to this protocol.
 @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
-public protocol Google_Firebase_Dataconnect_V1beta_ConnectorServiceAsyncProvider: CallHandlerProvider,
+public protocol Google_Firebase_Dataconnect_V1_ConnectorServiceAsyncProvider: CallHandlerProvider,
   Sendable {
   static var serviceDescriptor: GRPCServiceDescriptor { get }
-  var interceptors: Google_Firebase_Dataconnect_V1beta_ConnectorServiceServerInterceptorFactoryProtocol? {
+  var interceptors: Google_Firebase_Dataconnect_V1_ConnectorServiceServerInterceptorFactoryProtocol? {
     get
   }
 
   /// Execute a predefined query in a Connector.
-  func executeQuery(request: Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest,
+  func executeQuery(request: Google_Firebase_Dataconnect_V1_ExecuteQueryRequest,
                     context: GRPCAsyncServerCallContext) async throws
-    -> Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse
+    -> Google_Firebase_Dataconnect_V1_ExecuteQueryResponse
 
   /// Execute a predefined mutation in a Connector.
-  func executeMutation(request: Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest,
+  func executeMutation(request: Google_Firebase_Dataconnect_V1_ExecuteMutationRequest,
                        context: GRPCAsyncServerCallContext) async throws
-    -> Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse
+    -> Google_Firebase_Dataconnect_V1_ExecuteMutationResponse
 }
 
 @available(macOS 10.15, iOS 13, tvOS 13, watchOS 6, *)
-public extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceAsyncProvider {
+public extension Google_Firebase_Dataconnect_V1_ConnectorServiceAsyncProvider {
   static var serviceDescriptor: GRPCServiceDescriptor {
-    return Google_Firebase_Dataconnect_V1beta_ConnectorServiceServerMetadata.serviceDescriptor
+    return Google_Firebase_Dataconnect_V1_ConnectorServiceServerMetadata.serviceDescriptor
   }
 
   var serviceName: Substring {
-    return Google_Firebase_Dataconnect_V1beta_ConnectorServiceServerMetadata.serviceDescriptor
+    return Google_Firebase_Dataconnect_V1_ConnectorServiceServerMetadata.serviceDescriptor
       .fullName[...]
   }
 
-  var interceptors: Google_Firebase_Dataconnect_V1beta_ConnectorServiceServerInterceptorFactoryProtocol? {
+  var interceptors: Google_Firebase_Dataconnect_V1_ConnectorServiceServerInterceptorFactoryProtocol? {
     return nil
   }
 
@@ -384,11 +380,10 @@ public extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceAsyncProvide
       return GRPCAsyncServerHandler(
         context: context,
         requestDeserializer: ProtobufDeserializer<
-          Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest
-        >(),
-        responseSerializer: ProtobufSerializer<
-          Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse
+          Google_Firebase_Dataconnect_V1_ExecuteQueryRequest
         >(),
+        responseSerializer: ProtobufSerializer<Google_Firebase_Dataconnect_V1_ExecuteQueryResponse>(
+        ),
         interceptors: interceptors?.makeExecuteQueryInterceptors() ?? [],
         wrapping: { try await self.executeQuery(request: $0, context: $1) }
       )
@@ -397,10 +392,10 @@ public extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceAsyncProvide
       return GRPCAsyncServerHandler(
         context: context,
         requestDeserializer: ProtobufDeserializer<
-          Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest
+          Google_Firebase_Dataconnect_V1_ExecuteMutationRequest
         >(),
         responseSerializer: ProtobufSerializer<
-          Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse
+          Google_Firebase_Dataconnect_V1_ExecuteMutationResponse
         >(),
         interceptors: interceptors?.makeExecuteMutationInterceptors() ?? [],
         wrapping: { try await self.executeMutation(request: $0, context: $1) }
@@ -412,42 +407,42 @@ public extension Google_Firebase_Dataconnect_V1beta_ConnectorServiceAsyncProvide
   }
 }
 
-public protocol Google_Firebase_Dataconnect_V1beta_ConnectorServiceServerInterceptorFactoryProtocol: Sendable {
+public protocol Google_Firebase_Dataconnect_V1_ConnectorServiceServerInterceptorFactoryProtocol: Sendable {
   /// - Returns: Interceptors to use when handling 'executeQuery'.
   ///   Defaults to calling `self.makeInterceptors()`.
   func makeExecuteQueryInterceptors() -> [ServerInterceptor<
-    Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest,
-    Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse
+    Google_Firebase_Dataconnect_V1_ExecuteQueryRequest,
+    Google_Firebase_Dataconnect_V1_ExecuteQueryResponse
   >]
 
   /// - Returns: Interceptors to use when handling 'executeMutation'.
   ///   Defaults to calling `self.makeInterceptors()`.
   func makeExecuteMutationInterceptors() -> [ServerInterceptor<
-    Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest,
-    Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse
+    Google_Firebase_Dataconnect_V1_ExecuteMutationRequest,
+    Google_Firebase_Dataconnect_V1_ExecuteMutationResponse
   >]
 }
 
-public enum Google_Firebase_Dataconnect_V1beta_ConnectorServiceServerMetadata {
+public enum Google_Firebase_Dataconnect_V1_ConnectorServiceServerMetadata {
   public static let serviceDescriptor = GRPCServiceDescriptor(
     name: "ConnectorService",
-    fullName: "google.firebase.dataconnect.v1beta.ConnectorService",
+    fullName: "google.firebase.dataconnect.v1.ConnectorService",
     methods: [
-      Google_Firebase_Dataconnect_V1beta_ConnectorServiceServerMetadata.Methods.executeQuery,
-      Google_Firebase_Dataconnect_V1beta_ConnectorServiceServerMetadata.Methods.executeMutation,
+      Google_Firebase_Dataconnect_V1_ConnectorServiceServerMetadata.Methods.executeQuery,
+      Google_Firebase_Dataconnect_V1_ConnectorServiceServerMetadata.Methods.executeMutation,
     ]
   )
 
   public enum Methods {
     public static let executeQuery = GRPCMethodDescriptor(
       name: "ExecuteQuery",
-      path: "/google.firebase.dataconnect.v1beta.ConnectorService/ExecuteQuery",
+      path: "/google.firebase.dataconnect.v1.ConnectorService/ExecuteQuery",
       type: GRPCCallType.unary
     )
 
     public static let executeMutation = GRPCMethodDescriptor(
       name: "ExecuteMutation",
-      path: "/google.firebase.dataconnect.v1beta.ConnectorService/ExecuteMutation",
+      path: "/google.firebase.dataconnect.v1.ConnectorService/ExecuteMutation",
       type: GRPCCallType.unary
     )
   }
diff --git a/Sources/ProtoGen/connector_service.pb.swift b/Sources/ProtoGen/connector_service.pb.swift
index e15dc74..3c0239b 100644
--- a/Sources/ProtoGen/connector_service.pb.swift
+++ b/Sources/ProtoGen/connector_service.pb.swift
@@ -7,7 +7,7 @@
 // For information on using the generated types, please see the documentation:
 //   https://github.com/apple/swift-protobuf/
 
-// Copyright 2024 Google LLC
+// Copyright 2025 Google LLC
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -37,7 +37,7 @@ fileprivate struct _GeneratedWithProtocGenSwiftVersion: SwiftProtobuf.ProtobufAP
 }
 
 /// The ExecuteQuery request to Firebase Data Connect.
-public struct Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest {
+public struct Google_Firebase_Dataconnect_V1_ExecuteQueryRequest {
   // SwiftProtobuf.Message conformance is added in an extension below. See the
   // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
   // methods supported on all messages.
@@ -74,7 +74,7 @@ public struct Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest {
 }
 
 /// The ExecuteMutation request to Firebase Data Connect.
-public struct Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest {
+public struct Google_Firebase_Dataconnect_V1_ExecuteMutationRequest {
   // SwiftProtobuf.Message conformance is added in an extension below. See the
   // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
   // methods supported on all messages.
@@ -111,7 +111,7 @@ public struct Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest {
 }
 
 /// The ExecuteQuery response from Firebase Data Connect.
-public struct Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse {
+public struct Google_Firebase_Dataconnect_V1_ExecuteQueryResponse {
   // SwiftProtobuf.Message conformance is added in an extension below. See the
   // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
   // methods supported on all messages.
@@ -127,7 +127,7 @@ public struct Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse {
   public mutating func clearData() {self._data = nil}
 
   /// Errors of this response.
-  public var errors: [Google_Firebase_Dataconnect_V1beta_GraphqlError] = []
+  public var errors: [Google_Firebase_Dataconnect_V1_GraphqlError] = []
 
   public var unknownFields = SwiftProtobuf.UnknownStorage()
 
@@ -137,7 +137,7 @@ public struct Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse {
 }
 
 /// The ExecuteMutation response from Firebase Data Connect.
-public struct Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse {
+public struct Google_Firebase_Dataconnect_V1_ExecuteMutationResponse {
   // SwiftProtobuf.Message conformance is added in an extension below. See the
   // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
   // methods supported on all messages.
@@ -153,7 +153,7 @@ public struct Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse {
   public mutating func clearData() {self._data = nil}
 
   /// Errors of this response.
-  public var errors: [Google_Firebase_Dataconnect_V1beta_GraphqlError] = []
+  public var errors: [Google_Firebase_Dataconnect_V1_GraphqlError] = []
 
   public var unknownFields = SwiftProtobuf.UnknownStorage()
 
@@ -163,17 +163,17 @@ public struct Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse {
 }
 
 #if swift(>=5.5) && canImport(_Concurrency)
-extension Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest: @unchecked Sendable {}
-extension Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest: @unchecked Sendable {}
-extension Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse: @unchecked Sendable {}
-extension Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse: @unchecked Sendable {}
+extension Google_Firebase_Dataconnect_V1_ExecuteQueryRequest: @unchecked Sendable {}
+extension Google_Firebase_Dataconnect_V1_ExecuteMutationRequest: @unchecked Sendable {}
+extension Google_Firebase_Dataconnect_V1_ExecuteQueryResponse: @unchecked Sendable {}
+extension Google_Firebase_Dataconnect_V1_ExecuteMutationResponse: @unchecked Sendable {}
 #endif  // swift(>=5.5) && canImport(_Concurrency)
 
 // MARK: - Code below here is support for the SwiftProtobuf runtime.
 
-fileprivate let _protobuf_package = "google.firebase.dataconnect.v1beta"
+fileprivate let _protobuf_package = "google.firebase.dataconnect.v1"
 
-extension Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
+extension Google_Firebase_Dataconnect_V1_ExecuteQueryRequest: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
   public static let protoMessageName: String = _protobuf_package + ".ExecuteQueryRequest"
   public static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
     1: .same(proto: "name"),
@@ -212,7 +212,7 @@ extension Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest: SwiftProtobuf.
     try unknownFields.traverse(visitor: &visitor)
   }
 
-  public static func ==(lhs: Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest, rhs: Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest) -> Bool {
+  public static func ==(lhs: Google_Firebase_Dataconnect_V1_ExecuteQueryRequest, rhs: Google_Firebase_Dataconnect_V1_ExecuteQueryRequest) -> Bool {
     if lhs.name != rhs.name {return false}
     if lhs.operationName != rhs.operationName {return false}
     if lhs._variables != rhs._variables {return false}
@@ -221,7 +221,7 @@ extension Google_Firebase_Dataconnect_V1beta_ExecuteQueryRequest: SwiftProtobuf.
   }
 }
 
-extension Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
+extension Google_Firebase_Dataconnect_V1_ExecuteMutationRequest: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
   public static let protoMessageName: String = _protobuf_package + ".ExecuteMutationRequest"
   public static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
     1: .same(proto: "name"),
@@ -260,7 +260,7 @@ extension Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest: SwiftProtob
     try unknownFields.traverse(visitor: &visitor)
   }
 
-  public static func ==(lhs: Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest, rhs: Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest) -> Bool {
+  public static func ==(lhs: Google_Firebase_Dataconnect_V1_ExecuteMutationRequest, rhs: Google_Firebase_Dataconnect_V1_ExecuteMutationRequest) -> Bool {
     if lhs.name != rhs.name {return false}
     if lhs.operationName != rhs.operationName {return false}
     if lhs._variables != rhs._variables {return false}
@@ -269,7 +269,7 @@ extension Google_Firebase_Dataconnect_V1beta_ExecuteMutationRequest: SwiftProtob
   }
 }
 
-extension Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
+extension Google_Firebase_Dataconnect_V1_ExecuteQueryResponse: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
   public static let protoMessageName: String = _protobuf_package + ".ExecuteQueryResponse"
   public static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
     1: .same(proto: "data"),
@@ -303,7 +303,7 @@ extension Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse: SwiftProtobuf
     try unknownFields.traverse(visitor: &visitor)
   }
 
-  public static func ==(lhs: Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse, rhs: Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse) -> Bool {
+  public static func ==(lhs: Google_Firebase_Dataconnect_V1_ExecuteQueryResponse, rhs: Google_Firebase_Dataconnect_V1_ExecuteQueryResponse) -> Bool {
     if lhs._data != rhs._data {return false}
     if lhs.errors != rhs.errors {return false}
     if lhs.unknownFields != rhs.unknownFields {return false}
@@ -311,7 +311,7 @@ extension Google_Firebase_Dataconnect_V1beta_ExecuteQueryResponse: SwiftProtobuf
   }
 }
 
-extension Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
+extension Google_Firebase_Dataconnect_V1_ExecuteMutationResponse: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
   public static let protoMessageName: String = _protobuf_package + ".ExecuteMutationResponse"
   public static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
     1: .same(proto: "data"),
@@ -345,7 +345,7 @@ extension Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse: SwiftProto
     try unknownFields.traverse(visitor: &visitor)
   }
 
-  public static func ==(lhs: Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse, rhs: Google_Firebase_Dataconnect_V1beta_ExecuteMutationResponse) -> Bool {
+  public static func ==(lhs: Google_Firebase_Dataconnect_V1_ExecuteMutationResponse, rhs: Google_Firebase_Dataconnect_V1_ExecuteMutationResponse) -> Bool {
     if lhs._data != rhs._data {return false}
     if lhs.errors != rhs.errors {return false}
     if lhs.unknownFields != rhs.unknownFields {return false}
diff --git a/Sources/ProtoGen/graphql_error.pb.swift b/Sources/ProtoGen/graphql_error.pb.swift
index a4505ea..5a47b26 100644
--- a/Sources/ProtoGen/graphql_error.pb.swift
+++ b/Sources/ProtoGen/graphql_error.pb.swift
@@ -7,7 +7,7 @@
 // For information on using the generated types, please see the documentation:
 //   https://github.com/apple/swift-protobuf/
 
-// Copyright 2024 Google LLC
+// Copyright 2025 Google LLC
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -47,7 +47,7 @@ fileprivate struct _GeneratedWithProtocGenSwiftVersion: SwiftProtobuf.ProtobufAP
 /// - Upon query execution error, `ExecuteGraphql`, `ExecuteGraphqlRead`,
 /// `ExecuteMutation` and `ExecuteQuery` all return Code.OK with a list of
 /// `GraphqlError` in response body.
-public struct Google_Firebase_Dataconnect_V1beta_GraphqlError {
+public struct Google_Firebase_Dataconnect_V1_GraphqlError {
   // SwiftProtobuf.Message conformance is added in an extension below. See the
   // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
   // methods supported on all messages.
@@ -67,7 +67,7 @@ public struct Google_Firebase_Dataconnect_V1beta_GraphqlError {
   ///
   /// Omitted in `ExecuteMutation` and `ExecuteQuery` since the caller shouldn't
   /// have access access the underlying GQL source.
-  public var locations: [Google_Firebase_Dataconnect_V1beta_SourceLocation] = []
+  public var locations: [Google_Firebase_Dataconnect_V1_SourceLocation] = []
 
   /// The result field which could not be populated due to error.
   ///
@@ -85,8 +85,8 @@ public struct Google_Firebase_Dataconnect_V1beta_GraphqlError {
   public mutating func clearPath() {self._path = nil}
 
   /// Additional error information.
-  public var extensions: Google_Firebase_Dataconnect_V1beta_GraphqlErrorExtensions {
-    get {return _extensions ?? Google_Firebase_Dataconnect_V1beta_GraphqlErrorExtensions()}
+  public var extensions: Google_Firebase_Dataconnect_V1_GraphqlErrorExtensions {
+    get {return _extensions ?? Google_Firebase_Dataconnect_V1_GraphqlErrorExtensions()}
     set {_extensions = newValue}
   }
   /// Returns true if `extensions` has been explicitly set.
@@ -99,11 +99,11 @@ public struct Google_Firebase_Dataconnect_V1beta_GraphqlError {
   public init() {}
 
   fileprivate var _path: SwiftProtobuf.Google_Protobuf_ListValue? = nil
-  fileprivate var _extensions: Google_Firebase_Dataconnect_V1beta_GraphqlErrorExtensions? = nil
+  fileprivate var _extensions: Google_Firebase_Dataconnect_V1_GraphqlErrorExtensions? = nil
 }
 
 /// SourceLocation references a location in a GraphQL source.
-public struct Google_Firebase_Dataconnect_V1beta_SourceLocation {
+public struct Google_Firebase_Dataconnect_V1_SourceLocation {
   // SwiftProtobuf.Message conformance is added in an extension below. See the
   // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
   // methods supported on all messages.
@@ -122,7 +122,7 @@ public struct Google_Firebase_Dataconnect_V1beta_SourceLocation {
 /// GraphqlErrorExtensions contains additional information of `GraphqlError`.
 /// (-- TODO(b/305311379): include more detailed error fields:
 /// go/firemat:api:gql-errors.  --)
-public struct Google_Firebase_Dataconnect_V1beta_GraphqlErrorExtensions {
+public struct Google_Firebase_Dataconnect_V1_GraphqlErrorExtensions {
   // SwiftProtobuf.Message conformance is added in an extension below. See the
   // `Message` and `Message+*Additions` files in the SwiftProtobuf library for
   // methods supported on all messages.
@@ -138,16 +138,16 @@ public struct Google_Firebase_Dataconnect_V1beta_GraphqlErrorExtensions {
 }
 
 #if swift(>=5.5) && canImport(_Concurrency)
-extension Google_Firebase_Dataconnect_V1beta_GraphqlError: @unchecked Sendable {}
-extension Google_Firebase_Dataconnect_V1beta_SourceLocation: @unchecked Sendable {}
-extension Google_Firebase_Dataconnect_V1beta_GraphqlErrorExtensions: @unchecked Sendable {}
+extension Google_Firebase_Dataconnect_V1_GraphqlError: @unchecked Sendable {}
+extension Google_Firebase_Dataconnect_V1_SourceLocation: @unchecked Sendable {}
+extension Google_Firebase_Dataconnect_V1_GraphqlErrorExtensions: @unchecked Sendable {}
 #endif  // swift(>=5.5) && canImport(_Concurrency)
 
 // MARK: - Code below here is support for the SwiftProtobuf runtime.
 
-fileprivate let _protobuf_package = "google.firebase.dataconnect.v1beta"
+fileprivate let _protobuf_package = "google.firebase.dataconnect.v1"
 
-extension Google_Firebase_Dataconnect_V1beta_GraphqlError: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
+extension Google_Firebase_Dataconnect_V1_GraphqlError: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
   public static let protoMessageName: String = _protobuf_package + ".GraphqlError"
   public static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
     1: .same(proto: "message"),
@@ -191,7 +191,7 @@ extension Google_Firebase_Dataconnect_V1beta_GraphqlError: SwiftProtobuf.Message
     try unknownFields.traverse(visitor: &visitor)
   }
 
-  public static func ==(lhs: Google_Firebase_Dataconnect_V1beta_GraphqlError, rhs: Google_Firebase_Dataconnect_V1beta_GraphqlError) -> Bool {
+  public static func ==(lhs: Google_Firebase_Dataconnect_V1_GraphqlError, rhs: Google_Firebase_Dataconnect_V1_GraphqlError) -> Bool {
     if lhs.message != rhs.message {return false}
     if lhs.locations != rhs.locations {return false}
     if lhs._path != rhs._path {return false}
@@ -201,7 +201,7 @@ extension Google_Firebase_Dataconnect_V1beta_GraphqlError: SwiftProtobuf.Message
   }
 }
 
-extension Google_Firebase_Dataconnect_V1beta_SourceLocation: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
+extension Google_Firebase_Dataconnect_V1_SourceLocation: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
   public static let protoMessageName: String = _protobuf_package + ".SourceLocation"
   public static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
     1: .same(proto: "line"),
@@ -231,7 +231,7 @@ extension Google_Firebase_Dataconnect_V1beta_SourceLocation: SwiftProtobuf.Messa
     try unknownFields.traverse(visitor: &visitor)
   }
 
-  public static func ==(lhs: Google_Firebase_Dataconnect_V1beta_SourceLocation, rhs: Google_Firebase_Dataconnect_V1beta_SourceLocation) -> Bool {
+  public static func ==(lhs: Google_Firebase_Dataconnect_V1_SourceLocation, rhs: Google_Firebase_Dataconnect_V1_SourceLocation) -> Bool {
     if lhs.line != rhs.line {return false}
     if lhs.column != rhs.column {return false}
     if lhs.unknownFields != rhs.unknownFields {return false}
@@ -239,7 +239,7 @@ extension Google_Firebase_Dataconnect_V1beta_SourceLocation: SwiftProtobuf.Messa
   }
 }
 
-extension Google_Firebase_Dataconnect_V1beta_GraphqlErrorExtensions: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
+extension Google_Firebase_Dataconnect_V1_GraphqlErrorExtensions: SwiftProtobuf.Message, SwiftProtobuf._MessageImplementationBase, SwiftProtobuf._ProtoNameProviding {
   public static let protoMessageName: String = _protobuf_package + ".GraphqlErrorExtensions"
   public static let _protobuf_nameMap: SwiftProtobuf._NameMap = [
     1: .same(proto: "file"),
@@ -264,7 +264,7 @@ extension Google_Firebase_Dataconnect_V1beta_GraphqlErrorExtensions: SwiftProtob
     try unknownFields.traverse(visitor: &visitor)
   }
 
-  public static func ==(lhs: Google_Firebase_Dataconnect_V1beta_GraphqlErrorExtensions, rhs: Google_Firebase_Dataconnect_V1beta_GraphqlErrorExtensions) -> Bool {
+  public static func ==(lhs: Google_Firebase_Dataconnect_V1_GraphqlErrorExtensions, rhs: Google_Firebase_Dataconnect_V1_GraphqlErrorExtensions) -> Bool {
     if lhs.file != rhs.file {return false}
     if lhs.unknownFields != rhs.unknownFields {return false}
     return true