diff --git a/java-orchestration-airflow/google-cloud-orchestration-airflow/src/main/java/com/google/cloud/orchestration/airflow/service/v1/EnvironmentsClient.java b/java-orchestration-airflow/google-cloud-orchestration-airflow/src/main/java/com/google/cloud/orchestration/airflow/service/v1/EnvironmentsClient.java
index 0a5c76cd5e02..f2eb79a2f7c8 100644
--- a/java-orchestration-airflow/google-cloud-orchestration-airflow/src/main/java/com/google/cloud/orchestration/airflow/service/v1/EnvironmentsClient.java
+++ b/java-orchestration-airflow/google-cloud-orchestration-airflow/src/main/java/com/google/cloud/orchestration/airflow/service/v1/EnvironmentsClient.java
@@ -18,6 +18,7 @@
 
 import com.google.api.core.ApiFuture;
 import com.google.api.core.ApiFutures;
+import com.google.api.core.BetaApi;
 import com.google.api.gax.core.BackgroundResource;
 import com.google.api.gax.httpjson.longrunning.OperationsClient;
 import com.google.api.gax.longrunning.OperationFuture;
@@ -187,6 +188,7 @@ public final com.google.longrunning.OperationsClient getOperationsClient() {
    * Returns the OperationsClient that can be used to query the status of a long-running operation
    * returned by another API method call.
    */
+  @BetaApi
   public final OperationsClient getHttpJsonOperationsClient() {
     return httpJsonOperationsClient;
   }
diff --git a/java-orchestration-airflow/google-cloud-orchestration-airflow/src/main/java/com/google/cloud/orchestration/airflow/service/v1beta1/EnvironmentsClient.java b/java-orchestration-airflow/google-cloud-orchestration-airflow/src/main/java/com/google/cloud/orchestration/airflow/service/v1beta1/EnvironmentsClient.java
index ee96a4451119..4b68059b4e9b 100644
--- a/java-orchestration-airflow/google-cloud-orchestration-airflow/src/main/java/com/google/cloud/orchestration/airflow/service/v1beta1/EnvironmentsClient.java
+++ b/java-orchestration-airflow/google-cloud-orchestration-airflow/src/main/java/com/google/cloud/orchestration/airflow/service/v1beta1/EnvironmentsClient.java
@@ -189,6 +189,7 @@ public final com.google.longrunning.OperationsClient getOperationsClient() {
    * Returns the OperationsClient that can be used to query the status of a long-running operation
    * returned by another API method call.
    */
+  @BetaApi
   public final OperationsClient getHttpJsonOperationsClient() {
     return httpJsonOperationsClient;
   }
diff --git a/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1/environmentsclient/deleteenvironment/SyncDeleteEnvironment.java b/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1/environmentsclient/deleteenvironment/SyncDeleteEnvironment.java
index 12268034a064..ea8a6244314b 100644
--- a/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1/environmentsclient/deleteenvironment/SyncDeleteEnvironment.java
+++ b/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1/environmentsclient/deleteenvironment/SyncDeleteEnvironment.java
@@ -19,6 +19,7 @@
 // [START service_v1_generated_environmentsclient_deleteenvironment_sync]
 import com.google.cloud.orchestration.airflow.service.v1.DeleteEnvironmentRequest;
 import com.google.cloud.orchestration.airflow.service.v1.EnvironmentsClient;
+import com.google.protobuf.Empty;
 
 public class SyncDeleteEnvironment {
 
diff --git a/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1/environmentsclient/deleteenvironment/SyncDeleteEnvironmentString.java b/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1/environmentsclient/deleteenvironment/SyncDeleteEnvironmentString.java
index cde50771bfff..101560091193 100644
--- a/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1/environmentsclient/deleteenvironment/SyncDeleteEnvironmentString.java
+++ b/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1/environmentsclient/deleteenvironment/SyncDeleteEnvironmentString.java
@@ -18,6 +18,7 @@
 
 // [START service_v1_generated_environmentsclient_deleteenvironment_string_sync]
 import com.google.cloud.orchestration.airflow.service.v1.EnvironmentsClient;
+import com.google.protobuf.Empty;
 
 public class SyncDeleteEnvironmentString {
 
diff --git a/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1beta1/environmentsclient/deleteenvironment/SyncDeleteEnvironment.java b/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1beta1/environmentsclient/deleteenvironment/SyncDeleteEnvironment.java
index 2d1c807eefb7..c9efd7c485db 100644
--- a/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1beta1/environmentsclient/deleteenvironment/SyncDeleteEnvironment.java
+++ b/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1beta1/environmentsclient/deleteenvironment/SyncDeleteEnvironment.java
@@ -19,6 +19,7 @@
 // [START service_v1beta1_generated_environmentsclient_deleteenvironment_sync]
 import com.google.cloud.orchestration.airflow.service.v1beta1.DeleteEnvironmentRequest;
 import com.google.cloud.orchestration.airflow.service.v1beta1.EnvironmentsClient;
+import com.google.protobuf.Empty;
 
 public class SyncDeleteEnvironment {
 
diff --git a/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1beta1/environmentsclient/deleteenvironment/SyncDeleteEnvironmentString.java b/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1beta1/environmentsclient/deleteenvironment/SyncDeleteEnvironmentString.java
index c870a938fb6a..5c1f21fe0b72 100644
--- a/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1beta1/environmentsclient/deleteenvironment/SyncDeleteEnvironmentString.java
+++ b/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1beta1/environmentsclient/deleteenvironment/SyncDeleteEnvironmentString.java
@@ -18,6 +18,7 @@
 
 // [START service_v1beta1_generated_environmentsclient_deleteenvironment_string_sync]
 import com.google.cloud.orchestration.airflow.service.v1beta1.EnvironmentsClient;
+import com.google.protobuf.Empty;
 
 public class SyncDeleteEnvironmentString {
 
diff --git a/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1beta1/environmentsclient/updateenvironment/SyncUpdateEnvironmentStringEnvironmentFieldmask.java b/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1beta1/environmentsclient/updateenvironment/SyncUpdateEnvironmentStringEnvironmentFieldmask.java
index 768270271b6b..f20455ddfe1f 100644
--- a/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1beta1/environmentsclient/updateenvironment/SyncUpdateEnvironmentStringEnvironmentFieldmask.java
+++ b/java-orchestration-airflow/samples/snippets/generated/com/google/cloud/orchestration/airflow/service/v1beta1/environmentsclient/updateenvironment/SyncUpdateEnvironmentStringEnvironmentFieldmask.java
@@ -16,8 +16,7 @@
 
 package com.google.cloud.orchestration.airflow.service.v1beta1.samples;
 
-// [START
-// service_v1beta1_generated_environmentsclient_updateenvironment_stringenvironmentfieldmask_sync]
+// [START service_v1beta1_generated_environmentsclient_updateenvironment_stringenvironmentfieldmask_sync]
 import com.google.cloud.orchestration.airflow.service.v1beta1.Environment;
 import com.google.cloud.orchestration.airflow.service.v1beta1.EnvironmentsClient;
 import com.google.protobuf.FieldMask;
@@ -40,5 +39,4 @@ public static void syncUpdateEnvironmentStringEnvironmentFieldmask() throws Exce
     }
   }
 }
-// [END
-// service_v1beta1_generated_environmentsclient_updateenvironment_stringenvironmentfieldmask_sync]
+// [END service_v1beta1_generated_environmentsclient_updateenvironment_stringenvironmentfieldmask_sync]