honeymoose
/
hapi-fhir
mirror of https://github.com/hapifhir/hapi-fhir.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

review poitns finished

This commit is contained in:
leif stawnyczy 2024-03-12 10:25:58 -04:00
parent b3dcc17ccb
commit 88a916ece5
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hapi-fhir-jpaserver-base/src/main/java/ca/uhn/fhir/jpa/batch2/JpaJobPersistenceImpl.java
View File

@ -297,7 +297,9 @@ public class JpaJobPersistenceImpl implements IJobPersistence {
public void enqueueWorkChunkForProcessing(String theChunkId, Consumer<Integer> theCallback) { public void enqueueWorkChunkForProcessing(String theChunkId, Consumer<Integer> theCallback) {
int updated = myWorkChunkRepository.updateChunkStatus( int updated = myWorkChunkRepository.updateChunkStatus(
theChunkId, WorkChunkStatusEnum.QUEUED, WorkChunkStatusEnum.READY); theChunkId, WorkChunkStatusEnum.QUEUED, WorkChunkStatusEnum.READY);
theCallback.accept(updated); if (updated == 1) {
theCallback.accept(updated);
}
} }
@Override @Override

2
hapi-fhir-storage-batch2/src/test/java/ca/uhn/fhir/batch2/coordinator/JobCoordinatorImplTest.java
View File

@ -55,6 +55,7 @@ import static org.mockito.ArgumentMatchers.any;
import static org.mockito.ArgumentMatchers.anyInt; import static org.mockito.ArgumentMatchers.anyInt;
import static org.mockito.ArgumentMatchers.eq; import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.doReturn; import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.never;
import static org.mockito.Mockito.times; import static org.mockito.Mockito.times;
import static org.mockito.Mockito.verify; import static org.mockito.Mockito.verify;
import static org.mockito.Mockito.verifyNoMoreInteractions; import static org.mockito.Mockito.verifyNoMoreInteractions;
@ -476,6 +477,7 @@ public class JobCoordinatorImplTest extends BaseBatch2Test {
assertSame(jobDefinition, myJobDefinitionCaptor.getValue()); assertSame(jobDefinition, myJobDefinitionCaptor.getValue());
assertEquals(startRequest.getParameters(), myParametersJsonCaptor.getValue()); assertEquals(startRequest.getParameters(), myParametersJsonCaptor.getValue());
verify(myBatchJobSender, never()).sendWorkChannelMessage(any());
verifyNoMoreInteractions(myJobInstancePersister); verifyNoMoreInteractions(myJobInstancePersister);
verifyNoMoreInteractions(myStep1Worker); verifyNoMoreInteractions(myStep1Worker);
verifyNoMoreInteractions(myStep2Worker); verifyNoMoreInteractions(myStep2Worker);