Commit d67fddfb authored by Jessica Severin's avatar Jessica Severin
Browse files

forgot to set the workers batch_size from the analysis_stats object

(was still using the original idea of setting batch_size as
constant in the RunnableDB class).  Need to deprecate that idea.
parent 0ebacc18
...@@ -24,7 +24,7 @@ ...@@ -24,7 +24,7 @@
Each worker is linked to an analysis_id, registers its self on creation Each worker is linked to an analysis_id, registers its self on creation
into the Hive, creates a RunnableDB instance of the Analysis->module, into the Hive, creates a RunnableDB instance of the Analysis->module,
gets $runnable->batch_size() jobs from the analysis_job table, does its gets $worker->batch_size() jobs from the analysis_job table, does its
work, creates the next layer of analysis_job entries by interfacing to work, creates the next layer of analysis_job entries by interfacing to
the DataflowRuleAdaptor to determine the analyses it needs to pass it's the DataflowRuleAdaptor to determine the analyses it needs to pass it's
output data to and creates jobs on the next analysis's database. output data to and creates jobs on the next analysis's database.
...@@ -122,6 +122,7 @@ sub create_new_worker { ...@@ -122,6 +122,7 @@ sub create_new_worker {
if($worker and $analysisStats) { if($worker and $analysisStats) {
$analStatsDBA->update_status($analysis_id, 'WORKING'); $analStatsDBA->update_status($analysis_id, 'WORKING');
$worker->batch_size($analysisStats->batch_size);
} }
return $worker; return $worker;
} }
......
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