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

hooks only queued if their trigger job is successful (done)

Browse Source
This commit is contained in:
Oliver Gorwits
2023-04-30 22:59:20 +01:00
parent 949aeb9eea
commit 3f8ffe787f
4 changed files with 24 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
lib/App/Netdisco/Worker/Plugin/Arpnip/Hooks.pm
View File

@@ -11,6 +11,12 @@ register_worker({ phase => 'late' }, sub {
my ($job, $workerconf) = @_;
my $count = 0;
my $best = $job->best_status;
if (Status->$best->level != Status->done->level) {
return Status
->info(sprintf ' [%s] hooks - skipping due to incomplete job', $job->device);
}
foreach my $conf (@{ setting('hooks') }) {
my $no = ($conf->{'filter'}->{'no'} || []);
my $only = ($conf->{'filter'}->{'only'} || []);

6
lib/App/Netdisco/Worker/Plugin/Delete/Hooks.pm
View File

@@ -11,6 +11,12 @@ register_worker({ phase => 'late' }, sub {
my ($job, $workerconf) = @_;
my $count = 0;
my $best = $job->best_status;
if (Status->$best->level != Status->done->level) {
return Status
->info(sprintf ' [%s] hooks - skipping due to incomplete job', $job->device);
}
foreach my $conf (@{ setting('hooks') }) {
my $no = ($conf->{'filter'}->{'no'} || []);
my $only = ($conf->{'filter'}->{'only'} || []);

6
lib/App/Netdisco/Worker/Plugin/Discover/Hooks.pm
View File

@@ -11,6 +11,12 @@ register_worker({ phase => 'late' }, sub {
my ($job, $workerconf) = @_;
my $count = 0;
my $best = $job->best_status;
if (Status->$best->level != Status->done->level) {
return Status
->info(sprintf ' [%s] hooks - skipping due to incomplete job', $job->device);
}
foreach my $conf (@{ setting('hooks') }) {
my $no = ($conf->{'filter'}->{'no'} || []);
my $only = ($conf->{'filter'}->{'only'} || []);

6
lib/App/Netdisco/Worker/Plugin/Macsuck/Hooks.pm
View File

@@ -11,6 +11,12 @@ register_worker({ phase => 'late' }, sub {
my ($job, $workerconf) = @_;
my $count = 0;
my $best = $job->best_status;
if (Status->$best->level != Status->done->level) {
return Status
->info(sprintf ' [%s] hooks - skipping due to incomplete job', $job->device);
}
foreach my $conf (@{ setting('hooks') }) {
my $no = ($conf->{'filter'}->{'no'} || []);
my $only = ($conf->{'filter'}->{'only'} || []);