Commit 092a034f authored by Leo Gordon's avatar Leo Gordon
Browse files

now performing deep-stack substitution for whatever is dataflown into tables...

now performing deep-stack substitution for whatever is dataflown into tables (rather than just dataflowing the output_id)
parent 9d37369a
......@@ -83,7 +83,7 @@ sub url {
}
sub dataflow {
my ( $self, $output_ids ) = @_;
my ( $self, $output_ids, $emitting_job ) = @_;
# we have to do this the ugly way
# because Registry code currently prevents us from passing arguments to adaptors' new() methods
......@@ -92,7 +92,17 @@ sub dataflow {
$adaptor->table_name( $self->table_name() );
$adaptor->insertion_method( $self->insertion_method() );
$adaptor->store( $output_ids );
my @column_names = keys %{$self->adaptor->column_set};
my @rows = ();
foreach my $output_id (@$output_ids) {
my %row_hash = ();
foreach my $column (@column_names) {
$row_hash{ $column } = $emitting_job->_param_possibly_overridden($column, $output_id);
}
push @rows, \%row_hash;
}
$adaptor->store( \@rows );
}
......
......@@ -178,9 +178,7 @@ sub pipeline_analyses {
-module => 'Bio::EnsEMBL::Hive::RunnableDB::LongMult::AddTogether',
# -analysis_capacity => 0, # this is a way to temporarily block a given analysis
-flow_into => {
1 => { ':////final_result' => { 'a_multiplier' => '#a_multiplier#', 'b_multiplier' => '#b_multiplier#', 'result' => '#result#' },
'last' => undef,
},
1 => [ ':////final_result', 'last' ],
},
},
......
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