Skip to content

Commit fd263fc

Browse files
committed
[fix] ensure conversion hooks: skip removed module, fix stale comment
Signed-off-by: Artem Kuleshov <artem.kuleshov@flant.com>
1 parent 4d5debb commit fd263fc

2 files changed

Lines changed: 9 additions & 3 deletions

File tree

pkg/task/tasks/converge-modules/task.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -445,7 +445,7 @@ func (s *Task) CreateConvergeModulesTasks(state *module_manager.ModulesState, lo
445445
doModuleStartup = true
446446
}
447447

448-
// add EnsureHooks task for every enabled module, right after EnsureCRDs
448+
// add EnsureHooks after the optional EnsureCRDs, before ModuleRun
449449
if s.moduleManager.ModuleHasConversionWebhooks(moduleName) {
450450
resultingTasks = append(resultingTasks, s.newEnsureHooksTask(moduleName, newLogLabels, queuedAt))
451451
}
@@ -495,7 +495,7 @@ func (s *Task) CreateConvergeModulesTasks(state *module_manager.ModulesState, lo
495495
doModuleStartup = true
496496
}
497497

498-
// add EnsureHooks task for every enabled module, right after EnsureCRDs
498+
// add EnsureHooks after the optional EnsureCRDs, before ModuleRun
499499
if s.moduleManager.ModuleHasConversionWebhooks(modules[0]) {
500500
resultingTasks = append(resultingTasks, s.newEnsureHooksTask(modules[0], newLogLabels, queuedAt))
501501
}
@@ -551,7 +551,7 @@ func (s *Task) CreateConvergeModulesTasks(state *module_manager.ModulesState, lo
551551
doModuleStartup = true
552552
}
553553

554-
// add EnsureHooks task for every enabled module, right after EnsureCRDs
554+
// add EnsureHooks after the optional EnsureCRDs, before ModuleRun
555555
if s.moduleManager.ModuleHasConversionWebhooks(module) {
556556
resultingTasks = append(resultingTasks, s.newEnsureHooksTask(module, newLogLabels, queuedAt))
557557
}

pkg/task/tasks/module-ensure-hooks/task.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -69,6 +69,12 @@ func (s *Task) Handle(ctx context.Context) queue.TaskResult {
6969
}
7070

7171
baseModule := s.moduleManager.GetModule(hm.ModuleName)
72+
if baseModule == nil {
73+
// The module was removed between enqueue and execution; nothing to ensure.
74+
s.logger.Debug("module not found, skipping ensureHooks", slog.String(pkg.LogKeyName, hm.ModuleName))
75+
76+
return res
77+
}
7278

7379
s.logger.Debug("Module ensureHooks", slog.String(pkg.LogKeyName, hm.ModuleName))
7480

0 commit comments

Comments
 (0)