diff --git a/lib/App/Netdisco/Backend/Job.pm b/lib/App/Netdisco/Backend/Job.pm index 4488a58b..ea28c258 100644 --- a/lib/App/Netdisco/Backend/Job.pm +++ b/lib/App/Netdisco/Backend/Job.pm @@ -103,7 +103,7 @@ sub finalise_status { foreach my $status (reverse @{ $job->_statuslist }) { next if $status->phase - and $status->phase !~ m/^(?:check|early|main|store)$/; + and $status->phase !~ m/^(?:check|early|main|store|late)$/; # done() from check phase should not be the action's done() next if $status->phase eq 'check' and $status->is_ok; diff --git a/lib/App/Netdisco/Worker/Loader.pm b/lib/App/Netdisco/Worker/Loader.pm index 2c13ea1e..f8a94d1e 100644 --- a/lib/App/Netdisco/Worker/Loader.pm +++ b/lib/App/Netdisco/Worker/Loader.pm @@ -13,7 +13,8 @@ has [qw/workers_check workers_early workers_main workers_user - workers_store/] => ( is => 'rw' ); + workers_store + workers_late/] => ( is => 'rw' ); sub load_workers { my $self = shift; @@ -38,7 +39,7 @@ sub load_workers { my $workers = vars->{'workers'}->{$action} || {}; #use DDP; p vars->{'workers'}; - foreach my $phase (qw/check early main user store/) { + foreach my $phase (qw/check early main user store late/) { my $pname = "workers_${phase}"; my @wset = (); diff --git a/lib/App/Netdisco/Worker/Runner.pm b/lib/App/Netdisco/Worker/Runner.pm index 5166b56c..2c5e21ef 100644 --- a/lib/App/Netdisco/Worker/Runner.pm +++ b/lib/App/Netdisco/Worker/Runner.pm @@ -69,7 +69,7 @@ sub run { # run other phases if ($job->check_passed) { - $self->run_workers("workers_${_}") for qw/early main user store/; + $self->run_workers("workers_${_}") for qw/early main user store late/; } };