package crd

import (
	"gitea.com/logicamp/lc"
	"github.com/reactivex/rxgo/v2"
	"go.uber.org/zap"
	"sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
)

func (crd Crd) manageFinalizer(jobEventObservable rxgo.Observable) {
	for j := range jobEventObservable.Observe() {
		jobEvent := j.V.(*FlinkJobCrdEvent)
		lc.Logger.Debug("[crd] [manage-finalizer] adding finalizer for", zap.String("name", jobEvent.Job.GetName()))
		controllerutil.AddFinalizer(jobEvent.Job, "")
	}
}