Skip to content

Commit be2309e

Browse files
committedSep 12, 2024
#1078 asserting the table directories exists after running the pipeline
1 parent 1f8b957 commit be2309e

File tree

1 file changed

+11
-11
lines changed
  • gbif/ingestion/ingestion-integration-tests/src/test/java/org/gbif/pipelines/ingest/java/pipelines

1 file changed

+11
-11
lines changed
 

‎gbif/ingestion/ingestion-integration-tests/src/test/java/org/gbif/pipelines/ingest/java/pipelines/HdfsViewPipelineIT.java

+11-11
Original file line numberDiff line numberDiff line change
@@ -132,10 +132,10 @@ public void hdfsPipelineTest(String rootTestFolder, InterpretationType.RecordTyp
132132
assertFile(OccurrenceHdfsRecord.class, outputFn.apply(recordType.name().toLowerCase()));
133133
assertFile(MeasurementOrFactTable.class, outputFn.apply("measurementorfacttable"));
134134

135-
assertFileExistFalse(outputFn.apply("extendedmeasurementorfacttable"));
136-
assertFileExistFalse(outputFn.apply("germplasmmeasurementtrialtable"));
137-
assertFileExistFalse(outputFn.apply("permittable"));
138-
assertFileExistFalse(outputFn.apply("loantable"));
135+
assertFileExists(outputFn.apply("extendedmeasurementorfacttable"));
136+
assertFileExists(outputFn.apply("germplasmmeasurementtrialtable"));
137+
assertFileExists(outputFn.apply("permittable"));
138+
assertFileExists(outputFn.apply("loantable"));
139139
}
140140

141141
@Test
@@ -204,11 +204,11 @@ public void singleHdfsPipelineTest(
204204
+ "_147.avro";
205205

206206
assertFile(OccurrenceHdfsRecord.class, outputFn.apply(recordType.name().toLowerCase()));
207-
assertFileExistFalse(outputFn.apply("measurementorfacttable"));
208-
assertFileExistFalse(outputFn.apply("extendedmeasurementorfacttable"));
209-
assertFileExistFalse(outputFn.apply("germplasmmeasurementtrialtable"));
210-
assertFileExistFalse(outputFn.apply("permittable"));
211-
assertFileExistFalse(outputFn.apply("loantable"));
207+
assertFileExists(outputFn.apply("measurementorfacttable"));
208+
assertFileExists(outputFn.apply("extendedmeasurementorfacttable"));
209+
assertFileExists(outputFn.apply("germplasmmeasurementtrialtable"));
210+
assertFileExists(outputFn.apply("permittable"));
211+
assertFileExists(outputFn.apply("loantable"));
212212
}
213213

214214
@SneakyThrows
@@ -330,8 +330,8 @@ private void prepareTestData(
330330
}
331331
}
332332

333-
private void assertFileExistFalse(String output) {
334-
Assert.assertFalse(new File(output).exists());
333+
private void assertFileExists(String output) {
334+
Assert.assertTrue(new File(output).exists());
335335
}
336336

337337
private <T extends SpecificRecordBase> void assertFile(Class<T> clazz, String output)

0 commit comments

Comments
 (0)
Please sign in to comment.