Warning

This document is for an in-development version of Galaxy. You can alternatively view this page in the latest release if it exists or view the top of the latest release's documentation.

Source code for galaxy.jobs.splitters.basic

import logging

from . import multi

log = logging.getLogger(__name__)


[docs]def set_basic_defaults(job_wrapper): parent_job = job_wrapper.get_job() parallelism = job_wrapper.get_parallelism() parallelism.attributes["split_inputs"] = parent_job.input_datasets[0].name parallelism.attributes["merge_outputs"] = next(iter(job_wrapper.job_io.get_output_hdas_and_fnames()))
[docs]def do_split(job_wrapper): if len(job_wrapper.job_io.get_input_datasets()) > 1 or len(job_wrapper.job_io.get_output_fnames()) > 1: log.error("The basic splitter is not capable of handling jobs with multiple inputs or outputs.") raise Exception("Job Splitting Failed, the basic splitter only handles tools with one input and one output") # add in the missing information for splitting the one input and merging the one output set_basic_defaults(job_wrapper) return multi.do_split(job_wrapper)
[docs]def do_merge(job_wrapper, task_wrappers): # add in the missing information for splitting the one input and merging the one output set_basic_defaults(job_wrapper) return multi.do_merge(job_wrapper, task_wrappers)