From efd9a5238e777ebc530f2f54c3b4260b4a29caed Mon Sep 17 00:00:00 2001 From: fmendezh Date: Thu, 12 Sep 2024 16:14:14 +0200 Subject: [PATCH] https://github.com/gbif/pipelines/issues/1078 asserting the table directories exists after running the pipeline --- .../ingest/pipelines/HdfsViewPipelineIT.java | 24 +++++++++---------- 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/gbif/ingestion/ingestion-integration-tests/src/test/java/org/gbif/pipelines/ingest/pipelines/HdfsViewPipelineIT.java b/gbif/ingestion/ingestion-integration-tests/src/test/java/org/gbif/pipelines/ingest/pipelines/HdfsViewPipelineIT.java index a7b7dd456..71780fe89 100644 --- a/gbif/ingestion/ingestion-integration-tests/src/test/java/org/gbif/pipelines/ingest/pipelines/HdfsViewPipelineIT.java +++ b/gbif/ingestion/ingestion-integration-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 void assertFile(Class clazz, String output)