src/testJobs/java/org/apache/sdap/ningester/testjobs/AvhrrClimJobTest.java [74:99]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                .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));
    }

    @TestConfiguration
    static class NingesterApplicationTestsConfig {

        @Bean
        JobLauncherTestUtils jobLauncherTestUtils() {
            return new JobLauncherTestUtils();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/testJobs/java/org/apache/sdap/ningester/testjobs/AvhrrJobTest.java [74:99]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                .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));
    }

    @TestConfiguration
    static class NingesterApplicationTestsConfig {

        @Bean
        JobLauncherTestUtils jobLauncherTestUtils() {
            return new JobLauncherTestUtils();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -