Skip to content
Snippets Groups Projects
Commit 045f36b1 authored by Jessica Severin's avatar Jessica Severin
Browse files

added method flow_output_job, so this can be called independent of finishing

a job that has been flowed into an analysis/process
parent 3bd7c141
No related branches found
No related tags found
No related merge requests found
......@@ -280,8 +280,17 @@ sub worker_register_job_done {
return unless($job);
return unless($job->dbID and $job->adaptor and $job->hive_id);
return unless($worker and $worker->analysis and $worker->analysis->dbID);
$job->update_status('DONE');
}
sub flow_output_job {
my $self = shift;
my $job = shift;
return unless($job);
# create_next_jobs
my $rules = $self->db->get_DataflowRuleAdaptor->fetch_from_analysis_job($job);
foreach my $rule (@{$rules}) {
Bio::EnsEMBL::Hive::DBSQL::AnalysisJobAdaptor->CreateNewJob (
......@@ -290,9 +299,6 @@ sub worker_register_job_done {
-input_job_id => $job->dbID,
);
}
$job->update_status('DONE');
}
......
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