d8d1944d0653d08963bb46e956edaaab92d90f3a,workers/data_refinery_workers/processors/management/commands/queue_processor.py,Command,run_sra_processor,#Command#,33

Before Change

        processor_job = ProcessorJob.create_job_and_relationships(batches=[batch])
        processor_task = PROCESSOR_PIPELINE_LOOKUP[batch.pipeline_required]
        app.send_task(processor_task, args=[processor_job.id])
        logger.info("Processor Job queued.", processor_job=processor_job.id)

    def run_trasnscriptome_processor(self):
        // Create all the dummy data that would have been created

After Change

        processor_job = ProcessorJob.create_job_and_relationships(batches=[batch])
        logger.info("Queuing a processor job.")
        send_job(ProcessorPipeline[batch.pipeline_required], processor_job.id)

    def run_trasnscriptome_processor(self):
        // Create all the dummy data that would have been created
        // before a processor job could have been generated.

Instances