my ($module_or_file, $input_id, $flags, $flow_into, $language) = @_;
# Tell the Valley not to bother about the other meadows.
$Bio::EnsEMBL::Hive::Valley::_loaded_meadow_drivers = ['Bio::EnsEMBL::Hive::Meadow::LOCAL'],
# Worker control parameters:
#-job_limit => $job_limit,
#-life_span => $life_span,
-no_cleanup => $flags->{no_cleanup},
-no_write => $flags->{no_write},
#-worker_log_dir => $worker_log_dir,
#-hive_log_dir => $hive_log_dir,
#-retry_throwing_jobs => $retry_throwing_jobs,
#-can_respecialize => $can_respecialize,
# Other parameters:
);
# NOTE: `load_file_or_module` already checks that (Perl) modules can be compiled
my $runnable_module = $language ? $module_or_file : load_file_or_module( $module_or_file );
my ($dummy_analysis) = $hive_pipeline->add_new_or_update( 'Analysis', # NB: add_new_or_update returns a list
'logic_name' => 'Standalone_Dummy_Analysis', # looks nicer when printing out DFRs
'module' => $runnable_module,
'language' => $language,
);
'worker' => $worker,
'analysis' => $dummy_analysis,
);
$worker->current_role( $role );
'hive_pipeline' => $hive_pipeline,
'analysis' => $dummy_analysis,
'input_id' => $input_id,
);
$worker->compile_runnable;
my $runnable_object = $worker->runnable_object;
$job->load_parameters( $runnable_object );
if($flow_into) {
}
$runnable_object->input_job($job);
$runnable_object->life_cycle();
$runnable_object->cleanup_worker_temp_directory() unless $flags->{no_cleanup};
return !$job->died_somewhere()
}
Code:
