destinations.py

from galaxy.jobs import JobDestination
import os
import ast
from pprint import pprint


def bowtie2_wrapper(job):
    pprint(dir(job))
    pprint(job.get_parameters())
    for jp in job.get_parameters():
        if jp.name == "analysis_type":
            pprint(jp.value)
            jpv = ast.literal_eval(jp.value)
            ro = jpv.get("reporting_options")
            if ro is not None:
                ros = ro.get("reporting_options_selector")
                if ros == "a":
                    return 'multicore_local'
                if ros == "k":
                    k = ro.get("k")
                    print("k = %s" % k)
                    try:
                        kval = int(k)
                        if kval >= 40:
                            return 'multicore_local'
                    except ValueError:
                        pass
    return 'local'