From c83b9995977b486daeb806b1d09a33deabccf714 Mon Sep 17 00:00:00 2001 From: Oliver Gorwits Date: Sat, 17 May 2014 22:01:43 +0100 Subject: [PATCH] support disable manager from jobqueue dynamic code --- Netdisco/lib/App/Netdisco/Daemon/Worker/Manager.pm | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/Netdisco/lib/App/Netdisco/Daemon/Worker/Manager.pm b/Netdisco/lib/App/Netdisco/Daemon/Worker/Manager.pm index 39af503a..d77c6952 100644 --- a/Netdisco/lib/App/Netdisco/Daemon/Worker/Manager.pm +++ b/Netdisco/lib/App/Netdisco/Daemon/Worker/Manager.pm @@ -13,6 +13,10 @@ sub worker_begin { my $wid = $self->wid; debug "entering Manager ($wid) worker_begin()"; + if (setting('workers')->{'no_manager'}) { + return debug "mgr ($wid): no need for manager... skip begin"; + } + # requeue jobs locally debug "mgr ($wid): searching for jobs booked to this processing node"; my @jobs = $self->jq_locked; @@ -26,6 +30,10 @@ sub worker_begin { sub worker_body { my $self = shift; 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')->{$_} } values %{setting('job_type_keys')} );