diff --git a/internal/services/controllers/v1/olap/controller.go b/internal/services/controllers/v1/olap/controller.go index ca33432e9..a55f868dc 100644 --- a/internal/services/controllers/v1/olap/controller.go +++ b/internal/services/controllers/v1/olap/controller.go @@ -259,6 +259,7 @@ func (o *OLAPControllerImpl) Start() (func() error, error) { gocron.NewTask( o.runTenantTaskStatusUpdates(ctx), ), + gocron.WithSingletonMode(gocron.LimitModeReschedule), ) if err != nil { @@ -271,6 +272,7 @@ func (o *OLAPControllerImpl) Start() (func() error, error) { gocron.NewTask( o.runTenantDAGStatusUpdates(ctx), ), + gocron.WithSingletonMode(gocron.LimitModeReschedule), ) if err != nil {