Hi folks,

First of all, I really love the new job configuration style. It makes it very 
easy to change swaths of jobs and to streamline the way jobs are submitted to 
the cluster. I had no issues with the dynamic runner and I like the way that 
tags interact. My question is for the dynamic job runner; is it possible to 
send the job to a different job *handler* dynamically? Or is it already given 
to the default handler at the time that the dynamic function is called? I want 
to do something like this:

def ncbi_blastn_wrapper(job):
    # Send to a different handler?
    inp_data = dict( [ ( da.name, da.dataset ) for da in job.input_datasets ] )
    inp_data.update( [ ( da.name, da.dataset ) for da in 
job.input_library_datasets ] )
    query_file = inp_data[ "query" ].file_name
    query_size = os.path.getsize( query_file )
    if query_size > 1024 * 1024:
       handlername = "bighandler"
       handlername = "smallhandler"
    return JobDestination(runner="pbs", handler=handlername, 
params={"Resource_List": "24:00:00"})

The way I have it set up now, my handlers are pointing at different clusters 
with different capabilities, and it would be cool to make the decision which to 
run at runtime.

Thanks a ton!

Carrie Ganote
Please keep all replies on the list by using "reply all"
in your mail client.  To manage your subscriptions to this
and other Galaxy lists, please use the interface at:

To search Galaxy mailing lists use the unified search at:

Reply via email to