SubWorkflow "Unfulfilled dependency at run time"

[diegocorradini]

Hi all,

I am getting a weird results with my pipeline.
I have a pipeline with two subworkflow.
If I run my last_task in the SubSubworkflow the pipeline run in loop and I get the error "Unfulfilled dependency at run time".
While if I am moving it to SubWorkflow is working fine!

class MainWorkflow(sl.WorkflowTask):
    session_id = sl.Parameter()

    def workflow(self):
        tasks = []
        mates = self.get_input()
        for mate in mates:
            wf = self.new_task('sampleWF', SubWorkflow, session_id=str(self.session_id),
                           forward=mate['forward'], reverse=mate['reverse'])
            tasks.append(wf)
        return tasks

class SubWorkflow(sl.WorkflowTask):
    session_id = sl.Parameter()
    forward = sl.Parameter()
    reverse = sl.Parameter()

    def workflow(self):
       tasks = []
       aln_bwa = self.new_task('Alignment BWA WGS', task.ReadsAlignment, 
               input_r1= self.forward, input_r2=self.reverse)
       wf = self.new_task('Workflow', SubSubWorkflow, analysis_id=analysis.pk, 
in_aln=aln_bwa.out_alignment().path)

       tasks.append(wf)

       return wf

class SubSubWorkflow(sl.WorkflowTask):
    in_aln = sl.Parameter()
    analysis_id = sl.Parameter()

    def workflow(self):
        last_task = self.new_task('Sam to Sorted Indexed Bam', task.SamToSortedIndexedBam, sample_name=analysis.sample_name)
        last_task.in_last = self.in_aln
        return last_task

Any help would be really appreciate.

Diego