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 0a8ef3029..128762178 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 @@ -150,8 +150,6 @@ abstract class JobBase(operationDef: OperationDef, true case Some(chunk) => false - case Some(chunk) => - false } } } diff --git a/pramen/core/src/test/resources/log4j.properties b/pramen/core/src/test/resources/log4j.properties index 2ff2c9f3a..6d2eae20d 100644 --- a/pramen/core/src/test/resources/log4j.properties +++ b/pramen/core/src/test/resources/log4j.properties @@ -24,6 +24,7 @@ log4j.logger.za.co.absa.pramen.core.mocks.job.JobBaseDummy=OFF log4j.logger.za.co.absa.pramen.core.notify.SyncNotificationEmail=OFF log4j.logger.za.co.absa.pramen.core.reader.TableReaderJdbc=OFF log4j.logger.za.co.absa.pramen.core.runner.AppRunner$=OFF +log4j.logger.za.co.absa.pramen.core.runner.jobrunner.ConcurrentJobRunnerImpl=OFF log4j.logger.za.co.absa.pramen.core.runner.task.TaskRunnerBase=OFF log4j.logger.za.co.absa.pramen.core.runner.task.TaskRunnerMultithreaded=OFF log4j.logger.za.co.absa.pramen.core.runner.task.TaskRunnerParallel=OFF diff --git a/pramen/core/src/test/resources/log4j2.properties b/pramen/core/src/test/resources/log4j2.properties index 7282300c6..c8c58ca0a 100644 --- a/pramen/core/src/test/resources/log4j2.properties +++ b/pramen/core/src/test/resources/log4j2.properties @@ -49,6 +49,9 @@ logger.jdbcnativeutils.level = OFF logger.apprunner.name = za.co.absa.pramen.core.runner.AppRunner$ logger.apprunner.level = OFF +logger.concurrentjobrunner.name = za.co.absa.pramen.core.runner.jobrunner.ConcurrentJobRunnerImpl +logger.concurrentjobrunner.level = OFF + logger.taskrunnermultithreaded.name = za.co.absa.pramen.core.runner.task.TaskRunnerMultithreaded logger.taskrunnermultithreaded.level = OFF