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

add store phase

Browse Source
This commit is contained in:
Oliver Gorwits
2019-03-13 21:53:57 +00:00
parent 0c62159c85
commit 1ecd277e61
3 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
lib/App/Netdisco/Backend/Job.pm
View File

@@ -93,7 +93,7 @@ phase.
sub finalise_status { sub finalise_status {
my $job = shift; my $job = shift;
# use DDP; p $job->_statuslist; # use DDP; p $job->_statuslist;
# fallback # fallback
$job->status('error'); $job->status('error');
@@ -103,7 +103,7 @@ sub finalise_status {
foreach my $status (reverse @{ $job->_statuslist }) { foreach my $status (reverse @{ $job->_statuslist }) {
next if $status->phase next if $status->phase
and $status->phase !~ m/^(?:check|early|main)$/; and $status->phase !~ m/^(?:check|early|main|store)$/;
# done() from check phase should not be the action's done() # done() from check phase should not be the action's done()
next if $status->phase eq 'check' and $status->is_ok; next if $status->phase eq 'check' and $status->is_ok;

5
lib/App/Netdisco/Worker/Loader.pm
View File

@@ -12,7 +12,8 @@ use namespace::clean;
has [qw/workers_check has [qw/workers_check
workers_early workers_early
workers_main workers_main
workers_user/] => ( is => 'rw' ); workers_user
workers_store/] => ( is => 'rw' );
sub load_workers { sub load_workers {
my $self = shift; my $self = shift;
@@ -37,7 +38,7 @@ sub load_workers {
my $workers = vars->{'workers'}->{$action} || {}; my $workers = vars->{'workers'}->{$action} || {};
#use DDP; p vars->{'workers'}; #use DDP; p vars->{'workers'};
foreach my $phase (qw/check early main user/) { foreach my $phase (qw/check early main user store/) {
my $pname = "workers_${phase}"; my $pname = "workers_${phase}";
my @wset = (); my @wset = ();

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

@@ -69,7 +69,7 @@ sub run {
# run other phases # run other phases
if ($job->check_passed) { if ($job->check_passed) {
$self->run_workers("workers_${_}") for qw/early main user/; $self->run_workers("workers_${_}") for qw/early main user store/;
} }
}; };