https://github.com/gbif/pipelines/issues/1078

fixing it test, steps count
gbif · Sep 24, 2024 · b81871a · b81871a
1 parent 391ada1
commit b81871a
Show file tree

Hide file tree

Showing 6 changed files with 15 additions and 15 deletions.
diff --git a/...r/tasks-integration-tests/src/test/java/org/gbif/pipelines/tasks/PipelinesCallbackIT.java b/...r/tasks-integration-tests/src/test/java/org/gbif/pipelines/tasks/PipelinesCallbackIT.java
@@ -71,7 +71,7 @@ public void newFullIngestionCompletedTest() {
 
     // Should
     Map<StepType, PipelineStep> result = historyClient.getStepMap();
-    Assert.assertEquals(6, result.size());
+    Assert.assertEquals(7, result.size());
 
     Assert.assertEquals(1, historyClient.getPipelineExecutionMap().size());
     Assert.assertEquals(1, historyClient.getPipelineProcessMap().size());
@@ -138,7 +138,7 @@ public void newHalfIngestionCompletedTest() {
 
     // Should
     Map<StepType, PipelineStep> result = historyClient.getStepMap();
-    Assert.assertEquals(4, result.size());
+    Assert.assertEquals(5, result.size());
 
     Assert.assertEquals(1, historyClient.getPipelineExecutionMap().size());
     Assert.assertEquals(1, historyClient.getPipelineProcessMap().size());
@@ -242,7 +242,7 @@ public void newFullIngestionFailedTest() {
 
     // Should
     Map<StepType, PipelineStep> result = historyClient.getStepMap();
-    Assert.assertEquals(6, result.size());
+    Assert.assertEquals(7, result.size());
 
     Assert.assertEquals(1, historyClient.getPipelineExecutionMap().size());
     Assert.assertEquals(1, historyClient.getPipelineProcessMap().size());
@@ -329,7 +329,7 @@ public void twoStepsIngestionCompletedTest() {
 
     // Should
     Map<StepType, PipelineStep> result = historyClient.getStepMap();
-    Assert.assertEquals(6, result.size());
+    Assert.assertEquals(7, result.size());
 
     Assert.assertEquals(1, historyClient.getPipelineExecutionMap().size());
     Assert.assertEquals(1, historyClient.getPipelineProcessMap().size());

diff --git a/...ion-tests/src/test/java/org/gbif/pipelines/tasks/occurrences/hdfs/HdfsViewCallbackIT.java b/...ion-tests/src/test/java/org/gbif/pipelines/tasks/occurrences/hdfs/HdfsViewCallbackIT.java
@@ -78,7 +78,7 @@ public void successFullInterpretationTest() {
     assertTrue(path.toFile().exists());
 
     Map<StepType, PipelineStep> result = historyClient.getStepMap();
-    Assert.assertEquals(1, result.size());
+    Assert.assertEquals(2, result.size());
 
     Assert.assertEquals(1, historyClient.getPipelineExecutionMap().size());
     Assert.assertEquals(1, historyClient.getPipelineProcessMap().size());

diff --git a/...st/java/org/gbif/pipelines/tasks/occurrences/interpretation/InterpretationCallbackIT.java b/...st/java/org/gbif/pipelines/tasks/occurrences/interpretation/InterpretationCallbackIT.java
@@ -161,7 +161,7 @@ public void invalidChildSystemProcessTest() {
     assertEquals(0, PUBLISHER.getMessages().size());
 
     Map<StepType, PipelineStep> result = historyClient.getStepMap();
-    Assert.assertEquals(4, result.size());
+    Assert.assertEquals(5, result.size());
 
     Assert.assertEquals(1, historyClient.getPipelineExecutionMap().size());
     Assert.assertEquals(1, historyClient.getPipelineProcessMap().size());

diff --git a/...ion-tests/src/test/java/org/gbif/pipelines/tasks/verbatims/abcd/AbcdToAvroCallbackIT.java b/...ion-tests/src/test/java/org/gbif/pipelines/tasks/verbatims/abcd/AbcdToAvroCallbackIT.java
@@ -112,7 +112,7 @@ public void normalCaseWhenFilesInDirectoryTest() throws Exception {
     assertEquals(1, PUBLISHER.getMessages().size());
 
     Map<StepType, PipelineStep> result = historyClient.getStepMap();
-    Assert.assertEquals(6, result.size());
+    Assert.assertEquals(7, result.size());
 
     Assert.assertEquals(1, historyClient.getPipelineExecutionMap().size());
     Assert.assertEquals(1, historyClient.getPipelineProcessMap().size());
@@ -196,7 +196,7 @@ public void failedCaseWhenXmlAvroEmptyTest() {
     assertTrue(PUBLISHER.getMessages().isEmpty());
 
     Map<StepType, PipelineStep> result = historyClient.getStepMap();
-    Assert.assertEquals(6, result.size());
+    Assert.assertEquals(7, result.size());
 
     Assert.assertEquals(1, historyClient.getPipelineExecutionMap().size());
     Assert.assertEquals(1, historyClient.getPipelineProcessMap().size());

diff --git a/...ion-tests/src/test/java/org/gbif/pipelines/tasks/verbatims/dwca/DwcaToAvroCallbackIT.java b/...ion-tests/src/test/java/org/gbif/pipelines/tasks/verbatims/dwca/DwcaToAvroCallbackIT.java
@@ -139,7 +139,7 @@ public void normalCaseTest() throws Exception {
     assertEquals(1, PUBLISHER.getMessages().size());
 
     Map<StepType, PipelineStep> result = historyClient.getStepMap();
-    Assert.assertEquals(6, result.size());
+    Assert.assertEquals(7, result.size());
 
     Assert.assertEquals(1, historyClient.getPipelineExecutionMap().size());
     Assert.assertEquals(1, historyClient.getPipelineProcessMap().size());
@@ -216,7 +216,7 @@ public void csvCaseTest() throws Exception {
     assertEquals(1, PUBLISHER.getMessages().size());
 
     Map<StepType, PipelineStep> result = historyClient.getStepMap();
-    Assert.assertEquals(6, result.size());
+    Assert.assertEquals(7, result.size());
 
     Assert.assertEquals(1, historyClient.getPipelineExecutionMap().size());
     Assert.assertEquals(1, historyClient.getPipelineProcessMap().size());
@@ -293,7 +293,7 @@ public void xlsxCaseTest() throws Exception {
     assertEquals(1, PUBLISHER.getMessages().size());
 
     Map<StepType, PipelineStep> result = historyClient.getStepMap();
-    Assert.assertEquals(6, result.size());
+    Assert.assertEquals(7, result.size());
 
     Assert.assertEquals(1, historyClient.getPipelineExecutionMap().size());
     Assert.assertEquals(1, historyClient.getPipelineProcessMap().size());
@@ -448,7 +448,7 @@ public void normalSingleStepCaseTest() throws Exception {
     assertEquals(1, PUBLISHER.getMessages().size());
 
     Map<StepType, PipelineStep> result = historyClient.getStepMap();
-    Assert.assertEquals(6, result.size());
+    Assert.assertEquals(7, result.size());
 
     Assert.assertEquals(1, historyClient.getPipelineExecutionMap().size());
     Assert.assertEquals(1, historyClient.getPipelineProcessMap().size());
@@ -524,7 +524,7 @@ public void failedCaseTest() {
     assertTrue(PUBLISHER.getMessages().isEmpty());
 
     Map<StepType, PipelineStep> result = historyClient.getStepMap();
-    Assert.assertEquals(6, result.size());
+    Assert.assertEquals(7, result.size());
 
     Assert.assertEquals(1, historyClient.getPipelineExecutionMap().size());
     Assert.assertEquals(1, historyClient.getPipelineProcessMap().size());

diff --git a/...ation-tests/src/test/java/org/gbif/pipelines/tasks/verbatims/xml/XmlToAvroCallbackIT.java b/...ation-tests/src/test/java/org/gbif/pipelines/tasks/verbatims/xml/XmlToAvroCallbackIT.java
@@ -108,7 +108,7 @@ public void normalCaseWhenFilesInDirectoryTest() throws Exception {
     assertEquals(1, PUBLISHER.getMessages().size());
 
     Map<StepType, PipelineStep> result = historyClient.getStepMap();
-    Assert.assertEquals(6, result.size());
+    Assert.assertEquals(7, result.size());
 
     Assert.assertEquals(1, historyClient.getPipelineExecutionMap().size());
     Assert.assertEquals(1, historyClient.getPipelineProcessMap().size());
@@ -184,7 +184,7 @@ public void failedCaseWhenXmlAvroEmptyTest() {
     assertTrue(PUBLISHER.getMessages().isEmpty());
 
     Map<StepType, PipelineStep> result = historyClient.getStepMap();
-    Assert.assertEquals(6, result.size());
+    Assert.assertEquals(7, result.size());
 
     Assert.assertEquals(1, historyClient.getPipelineExecutionMap().size());
     Assert.assertEquals(1, historyClient.getPipelineProcessMap().size());