f84a1d058d5261a9b3122bf4320fe545ea69bb06,foreman/data_refinery_foreman/surveyor/test_end_to_end.py,GeoCelgzRedownloadingTestCase,test_geo_celgz_redownloading,#GeoCelgzRedownloadingTestCase#,338

Before Change

                )

                start_time = timezone.now()
                with self.assertRaises(ProcessorJob.DoesNotExist):
                    wait_for_job(doomed_processor_job, ProcessorJob, start_time)

            // The processor job that had a missing file will have
            // recreated its DownloaderJob, which means there should
            // now be SAMPLES_IN_EXPERIMENT + 1 downloader jobs.
            downloader_jobs = DownloaderJob.objects.all().order_by("-id")
            self.assertEqual(downloader_jobs.count(), SAMPLES_IN_EXPERIMENT + 1)

            // However DownloaderJobs don"t get queued immediately, so

After Change

            // recreated. The processor job that recreated that job has
            // abort=True
            logger.info("Downloader Jobs finished, waiting for processor Jobs to complete.")
            processor_jobs = ProcessorJob.objects.all().exclude(abort=True) // exclude aborted jobs
            for processor_job in processor_jobs:
                processor_job = wait_for_job(processor_job, ProcessorJob, start_time)
                self.assertTrue(processor_job.success)

Instances