shorten hook names
This commit is contained in:
@@ -65,7 +65,7 @@ register 'register_worker' => sub {
|
||||
};
|
||||
|
||||
my $primary = ($workerconf->{primary} ? '_primary' : '');
|
||||
my $hook = 'nd2worker_'. $action .'_'. $workerconf->{phase} . $primary;
|
||||
my $hook = 'nd2_'. $action .'_'. $workerconf->{phase} . $primary;
|
||||
my $store = Dancer::Factory::Hook->instance();
|
||||
|
||||
if (not $store->hook_is_registered($hook)) {
|
||||
|
||||
@@ -58,19 +58,19 @@ sub run {
|
||||
set(device_auth => \@newuserconf);
|
||||
|
||||
my $action = $job->action;
|
||||
my @phase_hooks = grep { m/^nd2worker_${action}_/ }
|
||||
my @phase_hooks = grep { m/^nd2_${action}_/ }
|
||||
@{ (setting('_nd2worker_hooks') || []) };
|
||||
|
||||
# run 00init primary
|
||||
my $store = Dancer::Factory::Hook->instance();
|
||||
my $initprimary = "nd2worker_${action}_00init_primary";
|
||||
my $initprimary = "nd2_${action}_00init_primary";
|
||||
if (scalar @{ $store->get_hooks_for($initprimary) }) {
|
||||
$self->run_workers($initprimary);
|
||||
return if $self->jobstat->not_ok;
|
||||
}
|
||||
|
||||
# run each 00init worker
|
||||
$self->run_workers("nd2worker_${action}_00init");
|
||||
$self->run_workers("nd2_${action}_00init");
|
||||
|
||||
# run primary
|
||||
$self->run_workers("${_}_primary") for (@phase_hooks);
|
||||
|
||||
Reference in New Issue
Block a user