zydronium/google-nomulus
1
0
Fork 0
mirror of https://github.com/google/nomulus.git synced 2025-08-12 12:39:39 +02:00
Code Issues Projects Releases Packages Wiki Activity

Use less strict isolation level in Spec11 pipeline (#1244)

Browse source
This commit is contained in:
sarahcaseybot 2021-07-16 15:46:34 -04:00 • committed by GitHub
parent e966598ea7
commit 87303cdf3b
1 changed files with 2 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

2
core/src/main/java/google/registry/beam/spec11/Spec11Pipeline.java
View file

@ -29,6 +29,7 @@ import google.registry.config.RegistryConfig.ConfigModule;
import google.registry.model.domain.DomainBase; import google.registry.model.domain.DomainBase;
import google.registry.model.reporting.Spec11ThreatMatch; import google.registry.model.reporting.Spec11ThreatMatch;
import google.registry.model.reporting.Spec11ThreatMatch.ThreatType; import google.registry.model.reporting.Spec11ThreatMatch.ThreatType;
import google.registry.persistence.PersistenceModule.TransactionIsolationLevel;
import google.registry.util.Retrier; import google.registry.util.Retrier;
import google.registry.util.SqlTemplate; import google.registry.util.SqlTemplate;
import google.registry.util.UtilsModule; import google.registry.util.UtilsModule;
@ -98,6 +99,7 @@ public class Spec11Pipeline implements Serializable {
} }
void setupPipeline(Pipeline pipeline) { void setupPipeline(Pipeline pipeline) {
options.setIsolationOverride(TransactionIsolationLevel.TRANSACTION_READ_COMMITTED);
PCollection<Subdomain> domains = PCollection<Subdomain> domains =
options.getDatabase().equals("DATASTORE") options.getDatabase().equals("DATASTORE")
? readFromBigQuery(options, pipeline) ? readFromBigQuery(options, pipeline)