diff --git a/dlp/snippets/snippets/src/main/java/com/example/dlp/Inspect.java b/dlp/snippets/snippets/src/main/java/com/example/dlp/Inspect.java
index b39be30adc7..28c958d0fcb 100644
--- a/dlp/snippets/snippets/src/main/java/com/example/dlp/Inspect.java
+++ b/dlp/snippets/snippets/src/main/java/com/example/dlp/Inspect.java
@@ -16,7 +16,7 @@
 
 package com.example.dlp;
 
-import com.google.api.gax.rpc.OperationFuture;
+import com.google.api.gax.longrunning.OperationFuture;
 import com.google.cloud.ServiceOptions;
 import com.google.cloud.dlp.v2beta1.DlpServiceClient;
 import com.google.longrunning.Operation;
@@ -235,7 +235,7 @@ private static void inspectGcsFile(
       OutputStorageConfig outputConfig = OutputStorageConfig.getDefaultInstance();
 
       // asynchronously submit an inspect operation
-      OperationFuture<InspectOperationResult, InspectOperationMetadata, Operation> responseFuture =
+      OperationFuture<InspectOperationResult, InspectOperationMetadata> responseFuture =
           dlpServiceClient.createInspectOperationAsync(inspectConfig, storageConfig, outputConfig);
 
       // ...
@@ -309,7 +309,7 @@ private static void inspectDatastore(
       OutputStorageConfig outputConfig = OutputStorageConfig.getDefaultInstance();
 
       // asynchronously submit an inspect operation
-      OperationFuture<InspectOperationResult, InspectOperationMetadata, Operation> responseFuture =
+      OperationFuture<InspectOperationResult, InspectOperationMetadata> responseFuture =
           dlpServiceClient.createInspectOperationAsync(inspectConfig, storageConfig, outputConfig);
 
       // ...
@@ -387,7 +387,7 @@ private static void inspectBigquery(
       OutputStorageConfig outputConfig = OutputStorageConfig.getDefaultInstance();
 
       // asynchronously submit an inspect operation
-      OperationFuture<InspectOperationResult, InspectOperationMetadata, Operation> responseFuture =
+      OperationFuture<InspectOperationResult, InspectOperationMetadata> responseFuture =
               dlpServiceClient.createInspectOperationAsync(
                   inspectConfig, storageConfig, outputConfig);
 
diff --git a/dlp/snippets/snippets/src/main/java/com/example/dlp/RiskAnalysis.java b/dlp/snippets/snippets/src/main/java/com/example/dlp/RiskAnalysis.java
index 5fc95bdec86..89cb840f2d0 100644
--- a/dlp/snippets/snippets/src/main/java/com/example/dlp/RiskAnalysis.java
+++ b/dlp/snippets/snippets/src/main/java/com/example/dlp/RiskAnalysis.java
@@ -16,7 +16,7 @@
 
 package com.example.dlp;
 
-import com.google.api.gax.rpc.OperationFuture;
+import com.google.api.gax.longrunning.OperationFuture;
 import com.google.cloud.ServiceOptions;
 import com.google.cloud.dlp.v2beta1.DlpServiceClient;
 import com.google.longrunning.Operation;
@@ -102,7 +102,7 @@ private static void calculateNumericalStats(
               .build();
 
       // asynchronously submit a risk analysis operation
-      OperationFuture<RiskAnalysisOperationResult, RiskAnalysisOperationMetadata, Operation>
+      OperationFuture<RiskAnalysisOperationResult, RiskAnalysisOperationMetadata>
           responseFuture = dlpServiceClient.analyzeDataSourceRiskAsync(request);
 
       // ...
@@ -180,7 +180,7 @@ private static void calculateCategoricalStats(
               .build();
 
       // asynchronously submit a risk analysis operation
-      OperationFuture<RiskAnalysisOperationResult, RiskAnalysisOperationMetadata, Operation>
+      OperationFuture<RiskAnalysisOperationResult, RiskAnalysisOperationMetadata>
           responseFuture = dlpServiceClient.analyzeDataSourceRiskAsync(request);
 
       // ...
@@ -259,7 +259,7 @@ private static void calculateKAnonymity(
               .build();
 
       // asynchronously submit a risk analysis operation
-      OperationFuture<RiskAnalysisOperationResult, RiskAnalysisOperationMetadata, Operation>
+      OperationFuture<RiskAnalysisOperationResult, RiskAnalysisOperationMetadata>
           responseFuture = dlpServiceClient.analyzeDataSourceRiskAsync(request);
 
       // ...
@@ -352,7 +352,7 @@ private static void calculateLDiversity(
               .build();
 
       // asynchronously submit a risk analysis operation
-      OperationFuture<RiskAnalysisOperationResult, RiskAnalysisOperationMetadata, Operation>
+      OperationFuture<RiskAnalysisOperationResult, RiskAnalysisOperationMetadata>
           responseFuture = dlpServiceClient.analyzeDataSourceRiskAsync(request);
 
       // ...