#1078 asserting the table directories exists after running the pipeline

gbif · Sep 12, 2024 · be2309e · be2309e
1 parent 1f8b957
commit be2309e
Showing 1 changed file with 11 additions and 11 deletions.
diff --git a/...tion-tests/src/test/java/org/gbif/pipelines/ingest/java/pipelines/HdfsViewPipelineIT.java b/...tion-tests/src/test/java/org/gbif/pipelines/ingest/java/pipelines/HdfsViewPipelineIT.java
@@ -132,10 +132,10 @@ public void hdfsPipelineTest(String rootTestFolder, InterpretationType.RecordTyp
     assertFile(OccurrenceHdfsRecord.class, outputFn.apply(recordType.name().toLowerCase()));
     assertFile(MeasurementOrFactTable.class, outputFn.apply("measurementorfacttable"));
 
-    assertFileExistFalse(outputFn.apply("extendedmeasurementorfacttable"));
-    assertFileExistFalse(outputFn.apply("germplasmmeasurementtrialtable"));
-    assertFileExistFalse(outputFn.apply("permittable"));
-    assertFileExistFalse(outputFn.apply("loantable"));
+    assertFileExists(outputFn.apply("extendedmeasurementorfacttable"));
+    assertFileExists(outputFn.apply("germplasmmeasurementtrialtable"));
+    assertFileExists(outputFn.apply("permittable"));
+    assertFileExists(outputFn.apply("loantable"));
   }
 
   @Test
@@ -204,11 +204,11 @@ public void singleHdfsPipelineTest(
                 + "_147.avro";
 
     assertFile(OccurrenceHdfsRecord.class, outputFn.apply(recordType.name().toLowerCase()));
-    assertFileExistFalse(outputFn.apply("measurementorfacttable"));
-    assertFileExistFalse(outputFn.apply("extendedmeasurementorfacttable"));
-    assertFileExistFalse(outputFn.apply("germplasmmeasurementtrialtable"));
-    assertFileExistFalse(outputFn.apply("permittable"));
-    assertFileExistFalse(outputFn.apply("loantable"));
+    assertFileExists(outputFn.apply("measurementorfacttable"));
+    assertFileExists(outputFn.apply("extendedmeasurementorfacttable"));
+    assertFileExists(outputFn.apply("germplasmmeasurementtrialtable"));
+    assertFileExists(outputFn.apply("permittable"));
+    assertFileExists(outputFn.apply("loantable"));
   }
 
   @SneakyThrows
@@ -330,8 +330,8 @@ private void prepareTestData(
     }
   }
 
-  private void assertFileExistFalse(String output) {
-    Assert.assertFalse(new File(output).exists());
+  private void assertFileExists(String output) {
+    Assert.assertTrue(new File(output).exists());
   }
 
   private <T extends SpecificRecordBase> void assertFile(Class<T> clazz, String output)