135/netdisco
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

support disable manager from jobqueue dynamic code

Browse Source
This commit is contained in:
Oliver Gorwits
2014-05-17 22:01:43 +01:00
parent 4792b0dc49
commit c83b999597
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
Netdisco/lib/App/Netdisco/Daemon/Worker/Manager.pm
View File

@@ -13,6 +13,10 @@ sub worker_begin {
my $wid = $self->wid; my $wid = $self->wid;
debug "entering Manager ($wid) worker_begin()"; debug "entering Manager ($wid) worker_begin()";
if (setting('workers')->{'no_manager'}) {
return debug "mgr ($wid): no need for manager... skip begin";
}
# requeue jobs locally # requeue jobs locally
debug "mgr ($wid): searching for jobs booked to this processing node"; debug "mgr ($wid): searching for jobs booked to this processing node";
my @jobs = $self->jq_locked; my @jobs = $self->jq_locked;
@@ -26,6 +30,10 @@ sub worker_begin {
sub worker_body { sub worker_body {
my $self = shift; my $self = shift;
my $wid = $self->wid; my $wid = $self->wid;
return debug "mgr ($wid): no need for manager... quitting"
if setting('workers')->{'no_manager'};
my $num_slots = sum( 0, map { setting('workers')->{$_} } my $num_slots = sum( 0, map { setting('workers')->{$_} }
values %{setting('job_type_keys')} ); values %{setting('job_type_keys')} );