package ticdc

import (
	"context"

	"github.com/tidbcloud/dataflow-service-ng/app/container"
	"go.uber.org/multierr"
)

func RunRegionalTiCDCClusterWorker(ctx context.Context) error {
	return multierr.Combine(
		container.Global().RegionalTiCDCClusterWorker.SyncAllTiCDCClusters(ctx),
	)
}