If you happen to see a question you know the answer to, please do chime in and help your fellow community members. We encourage our fourm members to be more involved, jump in and help out your fellow researchers with their questions. GATK forum is a community forum and helping each other with using GATK tools and research is the cornerstone of our success as a genomics research community.We appreciate your help!

Test-drive the GATK tools and Best Practices pipelines on Terra

Check out this blog post to learn how you can get started with GATK and try out the pipelines in preconfigured workspaces (with a user-friendly interface!) without having to install anything.
We will be out of the office on October 14, 2019, due to the U.S. holiday. We will return to monitoring the forum on October 15.

Local job with Queue while useing a cluster jobrunner

pjvthofpjvthof NLMember

Is there a way in Queue to let a job executed locally instead of submitting it to the cluster with drmaa? I know this must be possible since the scatter jobs are also not submitted at the cluster, could only not find how to do this.

For example I have a sniplet of a job that can easily run local:

class Ln extends CommandLineFunction {
  @Input(doc="Input file") var in: File = _
  @Output(doc="Link destination") var out: File = _

  def commandLine = {
    "ln -sf " + required(in) + required(out)

I hope you can help me out with this.


Best Answer


  • pjvthofpjvthof NLMember

    Thanks for the reply, this seems to work. I now have a function that looks like this:

    class Ln extends InProcessFunction {
      @Input(doc="Input file") var in: File = _
      @Output(doc="Link destination") var out: File = _
      override def run {
        val cmd = "ln -s " + in + " " + out
        val exitcode = cmd.!
        System.out.println("cmd: '" + cmd + "', exitcode: " + exitcode)

    Only not sure if the override is really needed but right now this seems to work.

Sign In or Register to comment.