741a954562bf99d23078b54eeb617f601a81f2af,workers/data_refinery_workers/processors/management/commands/queue_processor.py,Command,handle,#Command#,26

Before Change

    def handle(self, *args, **options):
        // Create all the dummy data that would have been created
        // before a processor job could have been generated.
        survey_job = SurveyJob(
            source_type="SRA"
        )
        survey_job.save()

        batch = Batch(
            survey_job=survey_job,
            source_type="SRA",
            size_in_bytes=2214725074,
            raw_format="fastq",
            processed_format="sf",
            pipeline_required="SALMON",
            platform_accession_code="IlluminaHiSeq2500",
            experiment_accession_code="PRJEB5018",
            experiment_title="It doesn"t really matter.",
            name="ERR1680082_1.fastq",
            internal_location="IlluminaHiSeq2500/SALMON",
            organism_id=10090,
            organism_name="MUS MUSCULUS",
            release_date="2014-03-25",
            last_uploaded_date="2016-05-20",
            status=BatchStatuses.NEW.value,
            download_url="ftp://ftp.sra.ebi.ac.uk/vol1/fastq/ERR168/002/ERR1680082/ERR1680082_1.fastq.gz"  // noqa
        )
        batch.save()

        batch2 = Batch(
            survey_job=survey_job,
            source_type="SRA",

After Change

            return 0
        elif options["processor-type"] == "TRANSCRIPTOME_INDEX":
            self.run_trasnscriptome_processor()
            return 0
        else:
            logger.error("Unrecognized processor-type.")
            return 1

Instances