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

make sure internal workers run before others

Browse Source
This commit is contained in:
Oliver Gorwits
2023-08-11 13:47:47 +01:00
parent 0ff88a8be2
commit c4ca7fa1da
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -39,6 +39,9 @@ sub load_workers {
my $workers = vars->{'workers'}->{$action} || {}; my $workers = vars->{'workers'}->{$action} || {};
# need to merge in internal workers without overriding action workers # need to merge in internal workers without overriding action workers
# we also drop any "stage" (sub-namespace) and install to "__internal__"
# which has higher run priority than "_base_" and any other.
foreach my $phase (qw/check early main user store late/) { foreach my $phase (qw/check early main user store late/) {
next unless exists vars->{'workers'}->{'internal'} next unless exists vars->{'workers'}->{'internal'}
and exists vars->{'workers'}->{'internal'}->{$phase}; and exists vars->{'workers'}->{'internal'}->{$phase};
@@ -46,7 +49,7 @@ sub load_workers {
foreach my $namespace (keys %{ $internal->{$phase} }) { foreach my $namespace (keys %{ $internal->{$phase} }) {
foreach my $priority (keys %{ $internal->{$phase}->{$namespace} }) { foreach my $priority (keys %{ $internal->{$phase}->{$namespace} }) {
push @{ $workers->{$phase}->{$namespace}->{$priority} }, push @{ $workers->{$phase}->{'__internal__'}->{$priority} },
@{ $internal->{$phase}->{$namespace}->{$priority} }; @{ $internal->{$phase}->{$namespace}->{$priority} };
} }
} }