Merge pull request #1318 from manitgupta:spanner-rpcPriority

PiperOrigin-RevId: 605338064
GoogleCloudPlatform · Feb 8, 2024 · c7cb59f · c7cb59f
2 parents 3be6f52 + eb6f02c
commit c7cb59f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...er/src/main/java/com/google/cloud/teleport/v2/templates/SpannerTransactionWriterDoFn.java b/...er/src/main/java/com/google/cloud/teleport/v2/templates/SpannerTransactionWriterDoFn.java
@@ -213,7 +213,9 @@ public void processElement(ProcessContext c) {
       // Start transaction
       spannerAccessor
           .getDatabaseClient()
-          .readWriteTransaction(Options.tag(getTxnTag(c.getPipelineOptions())))
+          .readWriteTransaction(
+              Options.tag(getTxnTag(c.getPipelineOptions())),
+              Options.priority(spannerConfig.getRpcPriority().get()))
           .run(
               (TransactionCallable<Void>)
                   transaction -> {