From 6849bf69147315cfedc78c52cfaeacd9f0ef1ab4 Mon Sep 17 00:00:00 2001
From: sarahcaseybot <sarahbot@google.com>
Date: Fri, 16 Jul 2021 15:46:34 -0400
Subject: [PATCH] Use less strict isolation level in Spec11 pipeline (#1244)

---
 .../main/java/google/registry/beam/spec11/Spec11Pipeline.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/core/src/main/java/google/registry/beam/spec11/Spec11Pipeline.java b/core/src/main/java/google/registry/beam/spec11/Spec11Pipeline.java
index 32030d5c3..4f03caa80 100644
--- a/core/src/main/java/google/registry/beam/spec11/Spec11Pipeline.java
+++ b/core/src/main/java/google/registry/beam/spec11/Spec11Pipeline.java
@@ -29,6 +29,7 @@ import google.registry.config.RegistryConfig.ConfigModule;
 import google.registry.model.domain.DomainBase;
 import google.registry.model.reporting.Spec11ThreatMatch;
 import google.registry.model.reporting.Spec11ThreatMatch.ThreatType;
+import google.registry.persistence.PersistenceModule.TransactionIsolationLevel;
 import google.registry.util.Retrier;
 import google.registry.util.SqlTemplate;
 import google.registry.util.UtilsModule;
@@ -98,6 +99,7 @@ public class Spec11Pipeline implements Serializable {
   }
 
   void setupPipeline(Pipeline pipeline) {
+    options.setIsolationOverride(TransactionIsolationLevel.TRANSACTION_READ_COMMITTED);
     PCollection<Subdomain> domains =
         options.getDatabase().equals("DATASTORE")
             ? readFromBigQuery(options, pipeline)