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

make psql worker primary, add hook debug log

Browse Source
This commit is contained in:
Oliver Gorwits
2017-09-06 18:27:34 +01:00
parent 36c70220a2
commit a59c23de79
2 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
lib/App/Netdisco/Worker/Plugin/Psql.pm
View File

@@ -2,10 +2,9 @@ package App::Netdisco::Worker::Plugin::Psql;
use Dancer ':syntax'; use Dancer ':syntax';
use App::Netdisco::Worker::Plugin; use App::Netdisco::Worker::Plugin;
use aliased 'App::Netdisco::Worker::Status'; use aliased 'App::Netdisco::Worker::Status';
register_worker(sub { register_worker({ primary => true }, sub {
my ($job, $workerconf) = @_; my ($job, $workerconf) = @_;
my ($device, $port, $extra) = map {$job->$_} qw/device port extra/; my ($device, $port, $extra) = map {$job->$_} qw/device port extra/;

6
lib/App/Netdisco/Worker/Runner.pm
View File

@@ -82,9 +82,11 @@ sub run {
sub run_workers { sub run_workers {
my $self = shift; my $self = shift;
my $hook = shift or return $self->jobstat->error('missing hook param'); my $hook = shift or return $self->jobstat->error('missing hook param');
my $primary = ($hook =~ m/_primary$/);
my $store = Dancer::Factory::Hook->instance(); my $store = Dancer::Factory::Hook->instance();
# debug "entering hook $hook"; my $primary = ($hook =~ m/_primary$/);
return unless scalar @{ $store->get_hooks_for($hook) };
debug "running workers for hook: $hook";
foreach my $worker (@{ $store->get_hooks_for($hook) }) { foreach my $worker (@{ $store->get_hooks_for($hook) }) {
try { try {