From ab0ee2422cd9df02af9815a9b4c2a9b7b0047857 Mon Sep 17 00:00:00 2001 From: Ruslan Iushchenko Date: Fri, 27 Sep 2024 16:53:30 +0200 Subject: [PATCH] Fix the check for retrospective updates. --- .../main/scala/za/co/absa/pramen/core/pipeline/JobBase.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pramen/core/src/main/scala/za/co/absa/pramen/core/pipeline/JobBase.scala b/pramen/core/src/main/scala/za/co/absa/pramen/core/pipeline/JobBase.scala index b47f0482a..ffb4f5a90 100644 --- a/pramen/core/src/main/scala/za/co/absa/pramen/core/pipeline/JobBase.scala +++ b/pramen/core/src/main/scala/za/co/absa/pramen/core/pipeline/JobBase.scala @@ -149,7 +149,7 @@ abstract class JobBase(operationDef: OperationDef, log.warn(s"${Emoji.WARNING} The dependent table '$table' has been updated at ${Instant.ofEpochSecond(chunk.jobFinished)} retrospectively " + s"after the transformation at ${Instant.ofEpochSecond(targetJobFinishedSeconds)} .") true - case Some(_) => + case _ => false } }