The following code works perfectly with one task but fails to process one input variable with two tasks, two input variables with three tasks, etc.
pipeline := Parallel
.Pipeline
.Stage(
procedure(const input, output: IOmniBlockingCollection)
var
NewAmt, OldAmt: Currenc...