Skip to content
This repository was archived by the owner on May 18, 2026. It is now read-only.
This repository was archived by the owner on May 18, 2026. It is now read-only.

Resolve input from all tasks in join  #35

Description

@thejmazz

mpileupandcall needs the reference and bam, but as the per the join lineage:

const call = join(alignAndSort, samtoolsIndex, mpileupandcall)

it will only receive whichever samtoolsIndex provides as resolved output, which will just be the bai.
alignAndSort produces the bam, and receives the reference.

Current fix is to add

skipPassed: true

to the task so that it resolves input glob patterns from fs and not the output of the previous task.

So perhaps store all input and outputs of all tasks in a join lineage, and resolve inputs for tasks later on.

Nextflow does this by declaring "channels", pushing files into them, and pulling files out of them, explicitly, in separate tasks. Problem with that was need to manually duplicate channels to use the same file in other downstream tasks.

Activity

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Metadata

Metadata

Assignees

Labels

Type

No type

Projects

No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions