adds singleton mode to task and dag updates (#1858)

This commit is contained in:
abelanger5
2025-06-12 10:33:19 -04:00
committed by GitHub
parent b5f430d95c
commit b5f370f1fa

View File

@@ -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 {