From 776db1f5d516dc277cdf7a9cfe7c1535f50701b9 Mon Sep 17 00:00:00 2001 From: astraw99 Date: Sun, 4 Jun 2023 23:44:20 +0800 Subject: [PATCH] Fix init DB conflict after leader election Signed-off-by: astraw99 --- workflow/controller/controller.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/workflow/controller/controller.go b/workflow/controller/controller.go index 274e5659c6d2..28d1bef56fad 100644 --- a/workflow/controller/controller.go +++ b/workflow/controller/controller.go @@ -187,8 +187,6 @@ func NewWorkflowController(ctx context.Context, restConfig *rest.Config, kubecli wfc.executorPlugins = map[string]map[string]*spec.Plugin{} } - wfc.UpdateConfig(ctx) - wfc.metrics = metrics.New(wfc.getMetricsServerConfig()) wfc.entrypoint = entrypoint.New(kubeclientset, wfc.Config.Images) @@ -240,6 +238,9 @@ var indexers = cache.Indexers{ func (wfc *WorkflowController) Run(ctx context.Context, wfWorkers, workflowTTLWorkers, podCleanupWorkers int) { defer runtimeutil.HandleCrash(runtimeutil.PanicHandlers...) + // init DB after leader election (if enabled) + wfc.UpdateConfig(ctx) + ctx, cancel := context.WithCancel(ctx) defer cancel()