This commit is contained in:
leif stawnyczy 2024-03-25 10:37:19 -04:00
parent db4ca99a3d
commit 6ac3c73234
3 changed files with 1 additions and 3 deletions

View File

@ -41,7 +41,6 @@ import ca.uhn.fhir.jpa.subscription.channel.api.IChannelReceiver;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.PlatformTransactionManager;
@Configuration
public abstract class BaseBatch2Config {

View File

@ -286,7 +286,7 @@ public class JobInstanceProcessor {
return new PagingIterator<>(WORK_CHUNK_METADATA_BATCH_SIZE, (index, batchsize, consumer) -> {
Pageable pageable = Pageable.ofSize(batchsize).withPage(index);
Page<WorkChunkMetadata> results = myJobPersistence.fetchAllWorkChunkMetadataForJobInStates(
pageable, myInstanceId, Set.of(WorkChunkStatusEnum.READY));
pageable, myInstanceId, Set.of(WorkChunkStatusEnum.READY));
for (WorkChunkMetadata metadata : results) {
consumer.accept(metadata);
}

View File

@ -40,7 +40,6 @@ import org.apache.commons.lang3.time.DateUtils;
import org.quartz.JobExecutionContext;
import org.slf4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.PlatformTransactionManager;
import java.util.HashSet;
import java.util.List;