This commit is contained in:
leif stawnyczy 2024-03-20 16:29:11 -04:00
parent 2037c01454
commit ccbd9afd98
2 changed files with 16 additions and 17 deletions

View File

@ -165,22 +165,21 @@ public class Batch2WorkChunkEntity implements Serializable {
public static Batch2WorkChunkEntity fromWorkChunk(WorkChunk theWorkChunk) { public static Batch2WorkChunkEntity fromWorkChunk(WorkChunk theWorkChunk) {
Batch2WorkChunkEntity entity = new Batch2WorkChunkEntity( Batch2WorkChunkEntity entity = new Batch2WorkChunkEntity(
theWorkChunk.getId(), theWorkChunk.getId(),
theWorkChunk.getSequence(), theWorkChunk.getSequence(),
theWorkChunk.getJobDefinitionId(), theWorkChunk.getJobDefinitionId(),
theWorkChunk.getJobDefinitionVersion(), theWorkChunk.getJobDefinitionVersion(),
theWorkChunk.getInstanceId(), theWorkChunk.getInstanceId(),
theWorkChunk.getTargetStepId(), theWorkChunk.getTargetStepId(),
theWorkChunk.getStatus(), theWorkChunk.getStatus(),
theWorkChunk.getCreateTime(), theWorkChunk.getCreateTime(),
theWorkChunk.getStartTime(), theWorkChunk.getStartTime(),
theWorkChunk.getUpdateTime(), theWorkChunk.getUpdateTime(),
theWorkChunk.getEndTime(), theWorkChunk.getEndTime(),
theWorkChunk.getErrorMessage(), theWorkChunk.getErrorMessage(),
theWorkChunk.getErrorCount(), theWorkChunk.getErrorCount(),
theWorkChunk.getRecordsProcessed(), theWorkChunk.getRecordsProcessed(),
theWorkChunk.getWarningMessage() theWorkChunk.getWarningMessage());
);
entity.setSerializedData(theWorkChunk.getData()); entity.setSerializedData(theWorkChunk.getData());
return entity; return entity;

View File

@ -28,7 +28,7 @@ public interface IInstanceStateTransitions extends IWorkChunkCommon, WorkChunkTe
Logger ourLog = LoggerFactory.getLogger(IInstanceStateTransitions.class); Logger ourLog = LoggerFactory.getLogger(IInstanceStateTransitions.class);
@Test @Test
default void createInstance_createsInQueuedWithChunk() { default void createInstance_createsInQueuedWithChunkInReady() {
// given // given
JobDefinition<?> jd = withJobDefinition(false); JobDefinition<?> jd = withJobDefinition(false);