Commit fe2a9468 authored by Matthieu Muffato's avatar Matthieu Muffato
Browse files

Better way of sharing the "take_time" parameter

parent 39a9b86b
...@@ -134,7 +134,7 @@ sub pipeline_analyses { ...@@ -134,7 +134,7 @@ sub pipeline_analyses {
{ 'a_multiplier' => '327358788', 'b_multiplier' => '9650156169' }, { 'a_multiplier' => '327358788', 'b_multiplier' => '9650156169' },
], ],
-flow_into => { -flow_into => {
2 => { 'part_multiply' => { 'a_multiplier' => '#a_multiplier#', 'digit' => '#digit#', 'take_time' => '#take_time#' } }, 2 => { 'part_multiply' => { 'a_multiplier' => '#a_multiplier#', 'digit' => '#digit#' } }, # do not need to include "take_time" because it is already "pipeline-wide"
1 => [ 'add_together' ], 1 => [ 'add_together' ],
}, },
}, },
......
...@@ -134,7 +134,7 @@ sub pipeline_analyses { ...@@ -134,7 +134,7 @@ sub pipeline_analyses {
], ],
-flow_into => { -flow_into => {
# will create a semaphored fan of jobs; will use a template to top-up the hashes: # will create a semaphored fan of jobs; will use a template to top-up the hashes:
'2->A' => { 'part_multiply' => { 'a_multiplier' => '#a_multiplier#', 'digit' => '#digit#', 'take_time' => '#take_time#' } }, '2->A' => { 'part_multiply' => { 'a_multiplier' => '#a_multiplier#', 'digit' => '#digit#' } }, # do not need to include "take_time" because it is already "pipeline-wide"
# will create a semaphored funnel job to wait for the fan to complete and add the results: # will create a semaphored funnel job to wait for the fan to complete and add the results:
'A->1' => [ 'add_together' ], 'A->1' => [ 'add_together' ],
}, },
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment