public void testJobCompletes()

in src/testJobs/java/org/apache/sdap/ningester/testjobs/AvhrrJobTest.java [70:92]

• 17 lines of code
• 1 McCabe index (conditional complexity)

    public void testJobCompletes() throws Exception {

        JobParameters jobParameters = new JobParametersBuilder()
                .addString("granule", "classpath:granules/20050101120000-NCEI-L4_GHRSST-SSTblend-AVHRR_OI-GLOB-v02.0-fv02.0.nc")
                .toJobParameters();

        JobExecution jobExecution = jobLauncherTestUtils.launchJob(jobParameters);

        assertThat(jobExecution.getExitStatus().getExitCode(), is("COMPLETED"));
        StepExecution stepExecution = jobExecution.getStepExecutions().iterator().next();
        assertThat(stepExecution.getReadCount(), is(1296));
        assertThat(stepExecution.getWriteCount(), is(1053));
        assertThat(stepExecution.getFilterCount(), is(243));

        assertEqualsEventually(1053L,
                () -> solrTemplate.count(datasourceProperties.getSolrStore().getCollection(),
                        new SimpleQuery("dataset_s: " + applicationProperties.getAddDatasetName().getDatasetName())),
                3);

        long cassandraCount = cassandraTemplate.count(datasourceProperties.getCassandraStore().getTableName());

        assertThat(cassandraCount, is(1053L));
    }