fix(hatchery:k8s): watch events routine auto restart (#6539)

Signed-off-by: richardlt <[email protected]>
ovh · Apr 20, 2023 · cfc9eb4 · cfc9eb4
1 parent 17ec69d
commit cfc9eb4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/engine/hatchery/kubernetes/kubernetes.go b/engine/hatchery/kubernetes/kubernetes.go
@@ -46,7 +46,7 @@ func (h *HatcheryKubernetes) InitHatchery(ctx context.Context) error {
 		h.routines(ctx)
 	})
 
-	h.GoRoutines.Run(ctx, "hatchery kubernetes watcher", func(ctx context.Context) {
+	h.GoRoutines.RunWithRestart(ctx, "hatchery kubernetes watcher", func(ctx context.Context) {
 		if err := h.WatchPodEvents(ctx); err != nil {
 			log.ErrorWithStackTrace(ctx, err)
 		}

diff --git a/engine/worker/cmd_run.go b/engine/worker/cmd_run.go
@@ -67,6 +67,7 @@ func runCmd() func(cmd *cobra.Command, args []string) {
 		go func() {
 			select {
 			case <-c:
+				log.Info(ctx, "Received syscall.SIGTERM")
 				cancel()
 				return
 			case <-ctx.Done():