#1078 asserting the table directories exists after running the pipeline

gbif · Sep 12, 2024 · efd9a52 · efd9a52
1 parent be2309e
commit efd9a52
Showing 1 changed file with 12 additions and 12 deletions.
diff --git a/...tegration-tests/src/test/java/org/gbif/pipelines/ingest/pipelines/HdfsViewPipelineIT.java b/...tegration-tests/src/test/java/org/gbif/pipelines/ingest/pipelines/HdfsViewPipelineIT.java
@@ -206,11 +206,11 @@ public void pipelineAllTest() throws Exception {
     assertFile(OccurrenceHdfsRecord.class, outputFn.apply("occurrence"));
     assertFile(MeasurementOrFactTable.class, outputFn.apply("measurementorfacttable"));
 
-    assertFileExistFalse(outputFn.apply("germplasmmeasurementtrialtable"));
-    assertFileExistFalse(outputFn.apply("audubontable"));
-    assertFileExistFalse(outputFn.apply("extendedmeasurementorfacttable"));
-    assertFileExistFalse(outputFn.apply("permittable"));
-    assertFileExistFalse(outputFn.apply("loantable"));
+    assertFileExists(outputFn.apply("germplasmmeasurementtrialtable"));
+    assertFileExists(outputFn.apply("audubontable"));
+    assertFileExists(outputFn.apply("extendedmeasurementorfacttable"));
+    assertFileExists(outputFn.apply("permittable"));
+    assertFileExists(outputFn.apply("loantable"));
   }
 
   @Test
@@ -379,15 +379,15 @@ public void pipelineHDFSTest(InterpretationType.RecordType recordType) throws Ex
                 + "_147-00000-of-00001.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"));
   }
 
-  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)