Skip to content

Commit c0266a8

Browse files
committed
[ci] iffing is hard ^2
Signed-off-by: Nicu Reut <nicu.reut@digitalasset.com>
1 parent 7989b90 commit c0266a8

File tree

1 file changed

+6
-4
lines changed

1 file changed

+6
-4
lines changed

apps/common/src/main/scala/org/lfdecentralizedtrust/splice/store/db/DbMultiDomainAcsStore.scala

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1006,10 +1006,12 @@ final class DbMultiDomainAcsStore[TXE](
10061006
case Some(lastIngestedOffset) =>
10071007
if (offset <= lastIngestedOffset) {
10081008
/* we can receive an offset equal to the last ingested and that can be safely ignore */
1009-
if (offset < lastIngestedOffset && isOffsetCheckpoint) {
1010-
logger.warn(
1011-
s"Checkpoint offset $offset < last ingested offset $lastIngestedOffset for DbMultiDomainAcsStore(storeId=$acsStoreId), skipping database actions. This is expected if the SQL query was automatically retried after a transient database error. Otherwise, this is unexpected and most likely caused by two identical UpdateIngestionService instances ingesting into the same logical database."
1012-
)
1009+
if (isOffsetCheckpoint) {
1010+
if (offset < lastIngestedOffset) {
1011+
logger.warn(
1012+
s"Checkpoint offset $offset < last ingested offset $lastIngestedOffset for DbMultiDomainAcsStore(storeId=$acsStoreId), skipping database actions. This is expected if the SQL query was automatically retried after a transient database error. Otherwise, this is unexpected and most likely caused by two identical UpdateIngestionService instances ingesting into the same logical database."
1013+
)
1014+
}
10131015
} else {
10141016
logger.warn(
10151017
s"Update offset $offset <= last ingested offset $lastIngestedOffset for DbMultiDomainAcsStore(storeId=$acsStoreId), skipping database actions. This is expected if the SQL query was automatically retried after a transient database error. Otherwise, this is unexpected and most likely caused by two identical UpdateIngestionService instances ingesting into the same logical database."

0 commit comments

Comments
 (0)