Fix typo in BsaRefreshAction (#2297)

This commit is contained in:
Weimin Yu 2024-01-22 16:03:35 -05:00 committed by GitHub
parent dc48c257b5
commit 8415c8bbe4
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 3 additions and 2 deletions

View file

@ -162,7 +162,7 @@ public class BsaRefreshAction implements Runnable {
.filter(UnblockableDomainChange::isNewOrChange) .filter(UnblockableDomainChange::isNewOrChange)
.map(UnblockableDomainChange::newValue)); .map(UnblockableDomainChange::newValue));
if (report.isPresent()) { if (report.isPresent()) {
gcsClient.logRemovedUnblockableDomainsReport( gcsClient.logAddedUnblockableDomainsReport(
schedule.jobName(), LINE_SPLITTER.splitToStream(report.get())); schedule.jobName(), LINE_SPLITTER.splitToStream(report.get()));
bsaReportSender.addUnblockableDomainsUpdates(report.get()); bsaReportSender.addUnblockableDomainsUpdates(report.get());
} else { } else {

View file

@ -48,7 +48,8 @@ public final class BsaTransactions {
@CanIgnoreReturnValue @CanIgnoreReturnValue
public static <T> T bsaQuery(Callable<T> work) { public static <T> T bsaQuery(Callable<T> work) {
verify(!isInTransaction(), "May only be used for top-level transactions."); verify(!isInTransaction(), "May only be used for top-level transactions.");
return replicaTm().transact(work, TRANSACTION_REPEATABLE_READ); // TRANSACTION_REPEATABLE_READ is default on replica.
return replicaTm().transact(work);
} }
private BsaTransactions() {} private BsaTransactions() {}