3. Exercise 2¶

A common mistake by developers is having the wrong channel type.

Nextflow distinguishes two different kinds of channels: queue channels and value channels.

• A queue channel is an asynchronous unidirectional FIFO queue that connects two processes or operators. Channel elements are consumed till the channel is empty.
• A value channel (a.k.a. a singleton channel) is bound to a single value and it can be read unlimited times without consuming its contents.

It is likely that one or more channel type has been converted to a queue channel and is only being read once.

In this example, the GATK_HAPLOTYPECALLER process is only executing one task.

You can see that the channel factory Channel.of has been used.

While parameters are treated as value channels, the Channel.of channel factory has converted these inputs to queue channels and are only being read once.

By removing these the inputs will be read multiple times.

Currently:

111
112
113
114
115
116
117

GATK_HAPLOTYPECALLER(
    SAMTOOLS_INDEX.out,
    Channel.of(params.genome_reference),
    Channel.of(params.genome_reference_index),
    Channel.of(params.genome_reference_dict),
    Channel.of(params.calling_intervals)
)

After:

GATK_HAPLOTYPECALLER(
    SAMTOOLS_INDEX.out,
    params.genome_reference,
    params.genome_reference_index,
    params.genome_reference_dict,
    params.calling_intervals
)